Class AsyncServer

Async server for session reduce operations.

Requires a SessionReducer implementation that provides the reduce function, accumulator serialization, and merge logic.

Index

Constructors

Methods

Constructors

constructor

new AsyncServer(sessionReducerImpl: SessionReducer): sessionReduce.AsyncServer
Create a new session reduce server.
Parameters
- sessionReducerImpl: SessionReducer
  Implementation of SessionReducer interface
Returns sessionReduce.AsyncServer
- Defined in index.ts:2032

Methods

start

start(socketPath?: string | null, serverInfoPath?: string | null): Promise<void>
Start the session reduce server.
Parameters
- OptionalsocketPath: string | null
  Optional custom Unix socket path
- OptionalserverInfoPath: string | null
  Optional path for server info file
Returns Promise<void>
- Defined in index.ts:2063

stop

stop(): void
Stop the server gracefully.

Returns void
- Defined in index.ts:2070