StreamManager

Defined in: packages/core/src/data/streaming/stream-manager.ts:124

Manages streaming connections (SSE and WebSocket).

Remarks

Provides a unified interface for managing multiple streaming connections, handling connection lifecycle, automatic reconnection, and message routing.

Features:

• Multiple concurrent connections
• Automatic reconnection with exponential backoff
• Connection state tracking
• Message counting and statistics
• Type-safe callbacks

Example

const manager = new StreamManager();

// Connect to SSE stream
await manager.connect('earthquake-feed', {
  type: 'sse',
  url: 'https://earthquake.usgs.gov/events',
  onData: (data) => updateMap(data),
  reconnect: { enabled: true }
});

// Connect to WebSocket stream
await manager.connect('vehicle-updates', {
  type: 'websocket',
  url: 'wss://transit.example.com/vehicles',
  onData: (data) => updateVehicles(data),
  protocols: ['json']
});

// Send data via WebSocket
manager.send('vehicle-updates', { type: 'subscribe', channel: 'all' });

// Check connection state
const state = manager.getState('earthquake-feed');
console.log(`Messages received: ${state?.messageCount}`);

// Disconnect when done
manager.disconnect('earthquake-feed');
manager.disconnectAll();

Constructors

Constructor

new StreamManager(): StreamManager

Returns

StreamManager

Methods

connect()

connect(id, config): Promise<void>

Defined in: packages/core/src/data/streaming/stream-manager.ts:143

Connect to a streaming source.

Parameters

Parameter	Type	Description
id	string	Unique identifier for this connection
config	StreamConfig	Stream configuration

Returns

Promise<void>

Throws

If a connection with the given id already exists

Example

await manager.connect('updates', {
  type: 'sse',
  url: 'https://api.example.com/stream',
  onData: (data) => console.log(data)
});

---

destroy()

destroy(): void

Defined in: packages/core/src/data/streaming/stream-manager.ts:292

Clean up all resources.

Returns

void

Example

manager.destroy();

---

disconnect()

disconnect(id): void

Defined in: packages/core/src/data/streaming/stream-manager.ts:179

Disconnect a specific stream.

Parameters

Parameter	Type	Description
id	string	Stream identifier

Returns

void

Example

manager.disconnect('updates');

---

disconnectAll()

disconnectAll(): void

Defined in: packages/core/src/data/streaming/stream-manager.ts:197

Disconnect all active streams.

Returns

void

Example

manager.disconnectAll();

---

getActiveIds()

getActiveIds(): string[]

Defined in: packages/core/src/data/streaming/stream-manager.ts:252

Get all active stream IDs.

Returns

string[]

Array of active stream identifiers

Example

const activeStreams = manager.getActiveIds();
console.log(`Active streams: ${activeStreams.join(', ')}`);

---

getState()

getState(id): StreamState | null

Defined in: packages/core/src/data/streaming/stream-manager.ts:218

Get the current state of a stream.

Parameters

Parameter	Type	Description
id	string	Stream identifier

Returns

StreamState | null

Stream state or null if not found

Example

const state = manager.getState('updates');
if (state) {
  console.log(`State: ${state.connectionState}`);
  console.log(`Messages: ${state.messageCount}`);
}

---

isConnected()

isConnected(id): boolean

Defined in: packages/core/src/data/streaming/stream-manager.ts:236

Check if a stream is currently connected.

Parameters

Parameter	Type	Description
id	string	Stream identifier

Returns

boolean

True if connected, false otherwise

Example

if (manager.isConnected('updates')) {
  console.log('Stream is active');
}

---

send()

send(id, data): void

Defined in: packages/core/src/data/streaming/stream-manager.ts:271

Send data to a WebSocket connection.

Parameters

Parameter	Type	Description
id	string	Stream identifier
data	unknown	Data to send (will be JSON stringified)

Returns

void

Throws

If stream is not a WebSocket connection or not connected

Example

manager.send('ws-updates', {
  type: 'subscribe',
  channels: ['news', 'sports']
});