transferum
    Preparing search index...

    Class ReadTransfer<T>

    Read adapter for an arbitrary OutputFlowInterface (e.g., Storage).

    Capabilities: isOutput, isPullable

    Mechanics:

    1. The constructor accepts config.flow: OutputFlowInterface
    2. pull() — returns flow.read()
    3. destroy() — does nothing (does not own the flow)

    Error handling:

    • If flow.read() throws an exception, onError is called.
    • With onError provided, the exception is suppressed, pull() returns undefined.
    • Without onError, the exception is rethrown.

    Configuration (ReadTransferConfig):

    • flow: OutputFlowInterface — target flow with a read() method
    • onError?: ErrorHandler — error handler

    Use cases:

    • Reading data from Storage (LatestStorage, QueueStorage, StackStorage)
    • Adapting an arbitrary object with read() to pipeline
    • Data source for polling transfers

    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: boolean = false
    isOutput: true
    isPollingProxy: boolean = false
    isPollingSource: boolean = false
    isPullable: true
    isPushable: boolean = false
    isSubscribable: boolean = false
    isTriggerable: boolean = false