• A processor that asynchronously resolves incoming events and sends them in the order they are received.

    Receives events or their promises from the given event sender, and sends them once they are resolved in the same order as they have been received. Mat send events in batches, e.g. when events resolved out of order.

    The resulting events supply is cut off if some of incoming event promises rejected. In this case the rejection reason is used as a reason to cut off. If incoming events supply is cut off, then the resulting event supply will be cut off too, but only after all incoming events resolved and sent.

    Type Parameters

    • TEvent

      Resolved event type.

    Parameters

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

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

    Returns OnEvent<[TEvent, ...TEvent[]]>

    New OnEvent sender of resolved events.

Generated using TypeDoc