Function handler

src/node/utils/streamErrors.ts:49–65

(error: unknown)

  options: StreamErrorHandlerOptions = {}
): () => void {
  const handler = (error: unknown) => {
    const normalized = normalizeError(error);
    const info: StreamErrorInfo = {
      label,
      code: getErrorCode(error),
      message: normalized.message,
    };

    if (isIgnorableStreamError(error)) {
      options.logger?.debug("Ignored stream error", info, normalized);
      options.onIgnorable?.(normalized, info);
      return;
    }

    options.logger?.warn("Stream error", info, normalized);
    options.onUnexpected?.(normalized, info);
  };

  emitter.on("error", handler);