@numaproj/numaflow-js - v0.0.0-alpha.4
    Preparing search index...

    Class AsyncServer

    Async server for handling map operations.

    const server = new map.AsyncServer(async (datum) => {
    const input = datum.value.toString();
    return [new map.Message(Buffer.from(input.toUpperCase()))];
    });

    await server.start();
    Index

    Constructors

    Methods

    Constructors

    Methods

    • Start the map server.

      Parameters

      • OptionalsocketPath: string | null

        Optional custom Unix socket path

      • OptionalserverInfoPath: string | null

        Optional path for server info file

      Returns Promise<void>

    • Stop the server gracefully.

      Returns void