Function eventHandler

src/cmap/wire_protocol/on_data.ts:110–114

(value: Uint8Array)

  return iterator;

  function eventHandler(value: Uint8Array) {
    const promise = unconsumedPromises.shift();
    if (promise != null) promise.resolve({ value, done: false });
    else unconsumedEvents.push(value);
  }

  function errorHandler(err: Error) {
    const promise = unconsumedPromises.shift();