ReactiveStreamSource

type ReactiveStreamSource<T> = object;

Duck-type for objects that build a ReactiveStreamStore on demand via a reactiveStore({ abortSignal }) method. Satisfied by PendingRpcSubscriptionsRequest<T>. Reactive-framework bindings (e.g. React's useSubscription) consume this duck-type so they don't have to name a concrete producer type.

Example

function bind<T>(source: ReactiveStreamSource<T>, abortSignal: AbortSignal) {
    return source.reactiveStore({ abortSignal });
}

See

Type Parameters

Type ParameterDescription
TThe value type emitted by the resulting stream store.

Methods

reactiveStore()

reactiveStore(options): ReactiveStreamStore<T>;

Parameters

ParameterType
options{ abortSignal: AbortSignal; }
options.abortSignalAbortSignal

Returns

ReactiveStreamStore<T>

On this page