Interface IReceiver

Hierarchy

IReceiver

Index

Properties

subscribe toSubscriptionIterator

Properties

subscribe

subscribe: (<T>(decoders: IDecoder<T> | IDecoder<T>[], callback: Callback<T>) => Unsubscribe | Promise<Unsubscribe>)

Type declaration

- <T>(decoders: IDecoder<T> | IDecoder<T>[], callback: Callback<T>): 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: IDecoder<T> | IDecoder<T>[]) => Promise<IAsyncIterator<T>>)

Type declaration

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

Generated using TypeDoc