transferum
    Preparing search index...

    Class AsyncStoredChannelTransfer<T>

    Output channel with value retention, external management, and async interface.

    Capabilities: isOutput, isSubscribable, isAsyncPullable, isAsyncTriggerable

    Mechanics:

    1. setup(emit) / destroy() — sync, like in StoredChannelTransfer
    2. emit(data) — sync, writes the value, calls asyncTrigger (fire-and-forget)
    3. asyncPull() — returns the current value (trivially async)
    4. asyncTrigger() — notifies subscribers (trivially async)
    5. subscribe(handler) — sync subscription

    Note: setup/emit/subscribe are synchronous (subscription remains sync), but pull/trigger are async for integration with async pipelines.

    Configuration (AsyncStoredChannelTransferConfig):

    • setup: (emit: DataHandler) => void
    • destroy: () => void
    • initialValue?: T
    • onError?, onDestroyError?: ErrorHandler

    Type Parameters

    • T

    Hierarchy (View Summary)

    Implements

    Index
    _destroy: () => void
    _emit: DataHandler<T>
    _state: ProxyReference<T>
    isAsyncPollingProxy: boolean = false
    isAsyncPullable: true
    isAsyncPushable: boolean = false
    isAsyncTriggerable: true
    isDuplex: boolean = false
    isGate: boolean = false
    isInput: boolean = false
    isOutput: true
    isPollingProxy: boolean = false
    isPollingSource: boolean = false
    isPullable: boolean = false
    isPushable: boolean = false
    isSubscribable: true
    isTriggerable: boolean = false