Class AsyncServer

Async server for reduce stream operations.

Example

const server = new reduceStream.AsyncServer(async function* (keys, datums, metadata) {
  for await (const datum of datums) {
    yield new reduceStream.Message(datum.value);
  }
});

Index

Constructors

constructor

Methods

start stop

Constructors

constructor

new AsyncServer(callbackFn: CallbackFn): reduceStream.AsyncServer
Create a new reduce stream server.
Parameters
- callbackFn: CallbackFn
  Async generator function that yields output messages
Returns reduceStream.AsyncServer
- Defined in index.ts:2267

Methods

start

start(socketPath?: string | null, serverInfoPath?: string | null): Promise<void>
Start the reduce stream 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:2292

stop

stop(): void
Stop the server gracefully.

Returns void
- Defined in index.ts:2299

Class AsyncServer

Example

Index

Constructors

Methods

Constructors

constructor

Parameters

Returns reduceStream.AsyncServer

Methods

start

Parameters

Returns Promise<void>

stop

Returns void

Settings

On This Page