Class InMemoryStreamManager

An in-memory implementation of StreamManager. Useful for testing or single-instance deployments where persistence is not required.

Implements

StreamManager

Index

Constructors

Methods

Constructors

constructor

new InMemoryStreamManager(
options?: { ttlSeconds?: number },
): InMemoryStreamManager
Parameters
- Optionaloptions: { ttlSeconds?: number }
  Configuration options.
  - OptionalttlSeconds?: number
    Time-to-live for streams in seconds. Defaults to 5 minutes.
Returns InMemoryStreamManager
- Defined in core/lib/action-D-zq6SnX.d.ts:584

Methods

open

open<S, O>(streamId: string): Promise<ActionStreamInput<S, O>>
Opens a stream for writing.
Type Parameters
- S
- O
Parameters
- streamId: string
  The unique identifier for the stream.
Returns Promise<ActionStreamInput<S, O>>
An object to write to the stream.
Implementation of StreamManager.open
- Defined in core/lib/action-D-zq6SnX.d.ts:588

subscribe<S, O>(
streamId: string,
subscriber: ActionStreamSubscriber<S, O>,
): Promise<{ unsubscribe: () => void }>
Subscribes to a stream to receive its events.
Type Parameters
- S
- O
Parameters
- streamId: string
  The unique identifier for the stream.
- subscriber: ActionStreamSubscriber<S, O>
  The subscriber callbacks.
Returns Promise<{ unsubscribe: () => void }>
A promise resolving to an object containing an unsubscribe function.
Implementation of StreamManager.subscribe
- Defined in core/lib/action-D-zq6SnX.d.ts:589