Interface IReceiver

Hierarchy

IReceiver

Index

Properties

getActiveSubscriptions subscribe toSubscriptionIterator

Properties

getActiveSubscriptions

getActiveSubscriptions: (() => ActiveSubscriptions)

Type declaration

- (): ActiveSubscriptions
- Returns ActiveSubscriptions

subscribe

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

Type declaration

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

toSubscriptionIterator

toSubscriptionIterator: (<T>(decoders: IDecoder<T> | IDecoder<T>[], opts?: ProtocolOptions) => Promise<IAsyncIterator<T>>)

Type declaration

- <T>(decoders: IDecoder<T> | IDecoder<T>[], opts?: ProtocolOptions): Promise<IAsyncIterator<T>>
- Type Parameters
  - T extends IDecodedMessage
  Parameters
  - decoders: IDecoder<T> | IDecoder<T>[]
  - Optional opts: ProtocolOptions
  Returns Promise<IAsyncIterator<T>>

Generated using TypeDoc