Function toAsyncIterator

toAsyncIterator<T>(receiver: IReceiver, decoder: IDecoder<T> | IDecoder<T>[], options?: ProtocolOptions, iteratorOptions?: IteratorOptions): Promise<IAsyncIterator<T>>
Function that transforms IReceiver subscription to iterable stream of data.

Returns
iterator and stop function to terminate it.
Type Parameters
- T extends IDecodedMessage
Parameters
- receiver: IReceiver
  
  object that allows to be subscribed to;
- decoder: IDecoder<T> | IDecoder<T>[]
  
  parameter to be passed to receiver for subscription;
- Optional options: ProtocolOptions
  
  options for receiver for subscription;
- Optional iteratorOptions: IteratorOptions
  
  optional configuration for iterator;
Returns Promise<IAsyncIterator<T>>
- Defined in packages/utils/dist/common/to_async_iterator.d.ts:20

Generated using TypeDoc