External module "operators/fromAsyncIterableDelayed"

fromAsyncIterableDelayed

• fromAsyncIterableDelayed<T>(this: ChannelWrapper<T>, ait: AsyncIterable<T>): ChannelWrapper<T>

• As soon as a value is ready to be taken from the async iterable put it into the channel on which this method was called, but wait until something is ready to take it before requesting the next one and putting it into the channel

  Type parameters

  • T

  Parameters

  • this: ChannelWrapper<T>

  • ait: AsyncIterable<T>

    an asyncIiterable

  Returns ChannelWrapper<T>

  the channel on which the method was called