Function toAsyncIterator

toAsyncIterator<T>(receiver: IReceiver, decoder: IDecoder<T> | IDecoder<T>[], 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 iteratorOptions: IteratorOptions
  
  optional configuration for iterator;
Returns Promise<IAsyncIterator<T>>
- Defined in packages/utils/src/common/to_async_iterator.ts:30

Generated using TypeDoc