Function toAsyncIterator

toAsyncIterator<T>(receiver, decoder, iteratorOptions?): Promise<IAsyncIterator<T>>
Function that transforms IReceiver subscription to iterable stream of data.
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: utils.IteratorOptions
  optional configuration for iterator;
Returns Promise<IAsyncIterator<T>>
iterator and stop function to terminate it.
- Defined in packages/utils/dist/common/to_async_iterator.d.ts:20