Перейти к содержанию



public func receive(driver: TransportDriver, filter: TransportFilter, assert: TransportFilter?, timeout: UInt?) async throws -> TransportPayload

Receive a specific message

This method awaits until a matching message is received (determined by filter) and resolves with message data. If an assert filter is specified, the message is also checked against it and throws if that assertion fails. Such behaviour comes handy for sudden unsubscribing, receiving messages out of order and other erroneous situations.


Name Description
driver TransportDriver implementation
filter incoming message filter
assert (optional) secondary incoming message filter, asserting out-of-order messages
timeout (optional) maximum await delay (in milliseconds), after which the receiver automatically unsubscribes



received message payload (TransportPayload) (both meta and data)