• Invokes an action for each element in the async-iterable sequence, and propagates all observer messages through the result sequence. This method can be used for debugging, logging, etc. by intercepting the message stream to run arbitrary actions for messages on the pipeline.

    Type Parameters

    • TSource

      The type of the elements in the source sequence.

    Parameters

    • observer: PartialAsyncObserver<TSource>

      Observer whose methods to invoke as part of the source sequence's observation.

    Returns MonoTypeOperatorAsyncFunction<TSource>

    The source sequence with the side-effecting behavior applied.

  • Invokes an action for each element in the async-iterable sequence, and propagates all observer messages through the result sequence. This method can be used for debugging, logging, etc. by intercepting the message stream to run arbitrary actions for messages on the pipeline.

    Type Parameters

    • TSource

      The type of the elements in the source sequence.

    Parameters

    • Optional next: null | ((value) => any)

      Function to invoke for each element in the async-iterable sequence.

    • Optional error: null | ((err) => any)

      Function to invoke upon exceptional termination of the async-iterable sequence.

    • Optional complete: null | (() => any)

      Function to invoke upon graceful termination of the async-iterable sequence.

    Returns MonoTypeOperatorAsyncFunction<TSource>

    The source sequence with the side-effecting behavior applied.

Generated using TypeDoc