ws-asyncapi API / query-core / streamStore

Function: streamStore()

streamStore(client, name, input, options?): Subscribable<StreamSnapshot<unknown>>

Defined in: .api-entries/query-core/index.d.ts:113

Consume a stream as a subscribable store. Default keeps the latest value (O(1)); pass reduce to accumulate. Iteration starts on first subscribe and is cancelled (StreamStop) when the last subscriber leaves.

Parameters

client

QueryCoreClient

name

string

input

unknown

options?

StreamReduce<unknown, unknown>

Returns

Subscribable<StreamSnapshot<unknown>>