• A processor that asynchronously resolves incoming events and sends then in the order of their resolution.

    Receives events or their promises from the given event sender, and sends them once they are resolved. The original order of events is not preserved. Instead each resolved event is sent along with its index in original order.

    The resulting events supply is cut off immediately once unresolved events supply is cut off, or some of incoming event promises rejected. In the latter case the rejection reason is used as a reason to cut off.

    Type Parameters

    • T

      A type of values the promises resolve to.

    Parameters

    • from: OnEvent<[T | PromiseLike<T>]>

      A sender of events or promise-like instances resolved to ones.

    Returns OnEvent<[T, number]>

    New OnEvent sender of resolved events and their indices in original order starting from 1.

Generated using TypeDoc