Interface IReceiver

interface IReceiver {
subscribe: (<T>(decoders, callback) => Unsubscribe | Promise<Unsubscribe>);
toSubscriptionIterator: (<T>(decoders) => Promise<IAsyncIterator<T>>);
}

Index

Properties

subscribe toSubscriptionIterator

Properties

subscribe

subscribe: (<T>(decoders, callback) => Unsubscribe | Promise<Unsubscribe>)

Type declaration

- <T>(decoders, callback): Unsubscribe | Promise<Unsubscribe>
- Type Parameters
  - T extends IDecodedMessage
  Parameters
  - decoders: IDecoder<T> | IDecoder<T>[]
  - callback: Callback<T>
  Returns Unsubscribe | Promise<Unsubscribe>

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>>

Generated using TypeDoc