transferum
    Preparing search index...

    Type Alias AsyncSinkTransferConfig<T>

    AsyncSinkTransferConfig: ErrorHandlingConfig<AsyncSinkTransfer<T>> & BackpressureConfig<
        T,
    > & { callback: AsyncDataHandler<T>
    | DataHandler<T>; ordered?: boolean }

    Configuration for AsyncSinkTransfer — sync or async callback invoked on each incoming data, with optional error handler, backpressure, and ordered execution.

    Type Parameters

    • T

    Type Declaration

    • Readonlycallback: AsyncDataHandler<T> | DataHandler<T>
    • Optional Readonlyordered?: boolean

      When true, callback invocations are executed sequentially in data-arrival order, regardless of their async duration. Default: false (unordered, backward-compatible).

    Settings
    Member Visibility