Function eventStreamReader

  • return an AsyncGenerator on event 'data' of string passed in argument rely on :createEventStreamTransform and node:events on api

    Example

    import { createReadStream } from 'node:fs';
    import { eventStreamReader } from './eventStreamReader.js';

    const stream = createReadStream('./test.txt', { encoding: 'utf8' });

    for await (const event of eventStreamReader(stream)) {
    console.log(event);
    }

    Parameters

    • stream: Readable

      A readable stream which output string or buffer of utf8 string

    • Optional signal: AbortSignal

      An AbortSignal to stop 'data' event listening

    Returns AsyncGenerator<IEvent, void, void>

Generated using TypeDoc