Function toAsyncIterator

  • toAsyncIterator<T>(receiver, decoder, iteratorOptions?): Promise<IAsyncIterator<T>>

  • Function that transforms IReceiver subscription to iterable stream of data.

    Type Parameters

    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.

Settings

Member Visibility

Theme

Generated using TypeDoc