Interface IReceiver

interface IReceiver {
subscribeWithUnsubscribe: SubscribeWithUnsubscribe;
toSubscriptionIterator: (<T>(decoders) => Promise<IAsyncIterator<T>>);
}

Index

Properties

subscribeWithUnsubscribe toSubscriptionIterator

Properties

subscribeWithUnsubscribe

subscribeWithUnsubscribe: SubscribeWithUnsubscribe

toSubscriptionIterator

toSubscriptionIterator: (<T>(decoders) => Promise<IAsyncIterator<T>>)

Type declaration

- <T>(decoders): Promise<IAsyncIterator<T>>
- Type Parameters
  - T extends IDecodedMessage
  Parameters
  - decoders: IDecoder<T> | IDecoder<T>[]
  Returns Promise<IAsyncIterator<T>>