transferum
    Preparing search index...

    Class WriteTransfer<T>

    Write adapter for an arbitrary InputFlowInterface (e.g., Storage).

    Capabilities: isInput, isPushable

    Mechanics:

    1. The constructor accepts config.flow: InputFlowInterface
    2. push(data) — calls flow.write(data)
    3. destroy() — does nothing (does not own the flow)

    Error handling:

    • If flow.write() throws an exception, onError is called.
    • With onError provided, the exception is suppressed. Without onError — rethrown.

    Configuration (WriteTransferConfig):

    • flow: InputFlowInterface — target flow with a write() method
    • onError?: ErrorHandler — error handler

    Use cases:

    • Writing data to Storage (LatestStorage, QueueStorage, StackStorage)
    • Adapting an arbitrary object with write() to pipeline
    • Finalization: saving the result to external storage

    Type Parameters

    • T

    Hierarchy (View Summary)

    Implements

    Index
    isAsyncPollingProxy: boolean = false
    isAsyncPullable: boolean = false
    isAsyncPushable: boolean = false
    isAsyncTriggerable: boolean = false
    isDuplex: boolean = false
    isGate: boolean = false
    isInput: true
    isOutput: boolean = false
    isPollingProxy: boolean = false
    isPollingSource: boolean = false
    isPullable: boolean = false
    isPushable: true
    isSubscribable: boolean = false
    isTriggerable: boolean = false