Class AsyncServer

Async server for reduce operations.

Index

Constructors

Methods

Constructors

constructor

new AsyncServer(reduceFn: Callback): reduce.AsyncServer
Create a new reduce server.
Parameters
- reduceFn: Callback
  Async function that aggregates datums by key
Returns reduce.AsyncServer
- Defined in index.ts:1812

Methods

start

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

stop

stop(): void
Stop the server gracefully.

Returns void
- Defined in index.ts:1833