Class SSEClient

Node SSE client: subscribe by [EventName], start/stop stream.

Indexable

[key: number]: () => void

Index

Constructors

Methods

free start stop subscribe unsubscribe

Constructors

constructor

new SSEClient(events_url: string): SSEClient
Parameters
- events_url: string
Returns SSEClient

Methods

free

free(): void

Returns void

start

start(start_from?: bigint): Promise<void>
Start streaming (wasm). Resolves when stopped, errored, or stream ends.
Parameters
- Optionalstart_from: bigint
Returns Promise<void>

stop

stop(): void

Stop the running stream loop.

Returns void

subscribe(event_name: string, handler: Function): void
Subscribe with a JS function handler (wasm).
Parameters
- event_name: string
- handler: Function
Returns void

unsubscribe

unsubscribe(event_name: string): void
Unsubscribe by event name string (wasm).
Parameters
- event_name: string
Returns void