Function attachStreamErrorHandler

src/node/utils/streamErrors.ts:44–72

(
  emitter: NodeJS.EventEmitter,
  label: string,
  options: StreamErrorHandlerOptions = {}
)

}

export function attachStreamErrorHandler(
  emitter: NodeJS.EventEmitter,
  label: string,
  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);

  return () => {
    emitter.removeListener("error", handler);
  };
}