Class AsyncServer

AsyncServer is a wrapper around a JavaScript callable that will be passed by the user to process the data received by the Sink.

Index

Constructors

Methods

Constructors

constructor

new AsyncServer(
    accumulatorFn: (
        datum: AsyncIterableIterator<accumulator.Datum>,
    ) => AsyncIterable<accumulator.Message>,
): accumulator.AsyncServer
Create a new Sink with the given callback.
Parameters
- accumulatorFn: (
  datum: AsyncIterableIterator<accumulator.Datum>,
  ) => AsyncIterable<accumulator.Message>
Returns accumulator.AsyncServer
- Defined in index.ts:546

Methods

start

start(socketPath?: string | null, serverInfoPath?: string | null): Promise<void>
Start the AsyncServer server with the given callback
Parameters
- OptionalsocketPath: string | null
- OptionalserverInfoPath: string | null
Returns Promise<void>
- Defined in index.ts:570

stop

stop(): void
Stop the AsyncServer server

Returns void
- Defined in index.ts:577