?HAMA

REDROOM

PHP 8.2.30

Path:

Navigation

Breadcrumbs

/ / proc / thread-self / root / home / byroehnu / .trash / node_modules11 / readable-stream / lib / internal / streams

Create

Create File | Create Folder | Upload Files | Run Command

Edit File Size: 3.01 KB

/proc/thread-self/root/home/byroehnu/.trash/node_modules11/readable-stream/lib/internal/streams/end-of-stream.js

Text Base64

// Ported from https://github.com/mafintosh/end-of-stream with
// permission from the author, Mathias Buus (@mafintosh).

'use strict';

var ERR_STREAM_PREMATURE_CLOSE = require('../../../errors').codes.ERR_STREAM_PREMATURE_CLOSE;
function once(callback) {
  var called = false;
  return function () {
    if (called) return;
    called = true;
    for (var _len = arguments.length, args = new Array(_len), _key = 0; _key < _len; _key++) {
      args[_key] = arguments[_key];
    }
    callback.apply(this, args);
  };
}
function noop() {}
function isRequest(stream) {
  return stream.setHeader && typeof stream.abort === 'function';
}
function eos(stream, opts, callback) {
  if (typeof opts === 'function') return eos(stream, null, opts);
  if (!opts) opts = {};
  callback = once(callback || noop);
  var readable = opts.readable || opts.readable !== false && stream.readable;
  var writable = opts.writable || opts.writable !== false && stream.writable;
  var onlegacyfinish = function onlegacyfinish() {
    if (!stream.writable) onfinish();
  };
  var writableEnded = stream._writableState && stream._writableState.finished;
  var onfinish = function onfinish() {
    writable = false;
    writableEnded = true;
    if (!readable) callback.call(stream);
  };
  var readableEnded = stream._readableState && stream._readableState.endEmitted;
  var onend = function onend() {
    readable = false;
    readableEnded = true;
    if (!writable) callback.call(stream);
  };
  var onerror = function onerror(err) {
    callback.call(stream, err);
  };
  var onclose = function onclose() {
    var err;
    if (readable && !readableEnded) {
      if (!stream._readableState || !stream._readableState.ended) err = new ERR_STREAM_PREMATURE_CLOSE();
      return callback.call(stream, err);
    }
    if (writable && !writableEnded) {
      if (!stream._writableState || !stream._writableState.ended) err = new ERR_STREAM_PREMATURE_CLOSE();
      return callback.call(stream, err);
    }
  };
  var onrequest = function onrequest() {
    stream.req.on('finish', onfinish);
  };
  if (isRequest(stream)) {
    stream.on('complete', onfinish);
    stream.on('abort', onclose);
    if (stream.req) onrequest();else stream.on('request', onrequest);
  } else if (writable && !stream._writableState) {
    // legacy streams
    stream.on('end', onlegacyfinish);
    stream.on('close', onlegacyfinish);
  }
  stream.on('end', onend);
  stream.on('finish', onfinish);
  if (opts.error !== false) stream.on('error', onerror);
  stream.on('close', onclose);
  return function () {
    stream.removeListener('complete', onfinish);
    stream.removeListener('abort', onclose);
    stream.removeListener('request', onrequest);
    if (stream.req) stream.req.removeListener('finish', onfinish);
    stream.removeListener('end', onlegacyfinish);
    stream.removeListener('close', onlegacyfinish);
    stream.removeListener('finish', onfinish);
    stream.removeListener('end', onend);
    stream.removeListener('error', onerror);
    stream.removeListener('close', onclose);
  };
}
module.exports = eos;

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Directory Contents

Dirs: 0 × Files: 10

Sort:

Enable drag-to-move

	Name	Size	Perms	Modified	Actions
	async_iterator.js	6.32 KB	lrw-r--r--	2026-02-21 00:53:30	Edit Download recursive recursive
	buffer_list.js	6.74 KB	lrw-r--r--	2026-02-21 00:53:32	Edit Download recursive recursive
	destroy.js	3.04 KB	lrw-r--r--	2026-02-21 00:53:34	Edit Download recursive recursive
	end-of-stream.js	3.01 KB	lrw-r--r--	2026-02-21 00:53:34	Edit Download recursive recursive
	from-browser.js	101 B	lrw-r--r--	2026-02-21 00:53:36	Edit Download recursive recursive
	from.js	3.58 KB	lrw-r--r--	2026-02-21 00:53:38	Edit Download recursive recursive
	pipeline.js	2.36 KB	lrw-r--r--	2026-02-21 00:53:38	Edit Download recursive recursive
	state.js	745 B	lrw-r--r--	2026-02-21 00:53:40	Edit Download recursive recursive
	stream-browser.js	49 B	lrw-r--r--	2026-02-21 00:53:42	Edit Download recursive recursive
	stream.js	36 B	lrw-r--r--	2026-02-21 00:53:42	Edit Download recursive recursive