summaryrefslogtreecommitdiff
path: root/includes/external/addressbook/node_modules/http2-wrapper/source/incoming-message.js
diff options
context:
space:
mode:
authorRaindropsSys <raindrops@equestria.dev>2023-11-17 23:25:29 +0100
committerRaindropsSys <raindrops@equestria.dev>2023-11-17 23:25:29 +0100
commit953ddd82e48dd206cef5ac94456549aed13b3ad5 (patch)
tree8f003106ee2e7f422e5a22d2ee04d0db302e66c0 /includes/external/addressbook/node_modules/http2-wrapper/source/incoming-message.js
parent62a9199846b0c07c03218703b33e8385764f42d9 (diff)
downloadpluralconnect-953ddd82e48dd206cef5ac94456549aed13b3ad5.tar.gz
pluralconnect-953ddd82e48dd206cef5ac94456549aed13b3ad5.tar.bz2
pluralconnect-953ddd82e48dd206cef5ac94456549aed13b3ad5.zip
Updated 30 files and deleted 2976 files (automated)
Diffstat (limited to 'includes/external/addressbook/node_modules/http2-wrapper/source/incoming-message.js')
-rw-r--r--includes/external/addressbook/node_modules/http2-wrapper/source/incoming-message.js73
1 files changed, 0 insertions, 73 deletions
diff --git a/includes/external/addressbook/node_modules/http2-wrapper/source/incoming-message.js b/includes/external/addressbook/node_modules/http2-wrapper/source/incoming-message.js
deleted file mode 100644
index 780e051..0000000
--- a/includes/external/addressbook/node_modules/http2-wrapper/source/incoming-message.js
+++ /dev/null
@@ -1,73 +0,0 @@
-'use strict';
-const {Readable} = require('stream');
-
-class IncomingMessage extends Readable {
- constructor(socket, highWaterMark) {
- super({
- emitClose: false,
- autoDestroy: true,
- highWaterMark
- });
-
- this.statusCode = null;
- this.statusMessage = '';
- this.httpVersion = '2.0';
- this.httpVersionMajor = 2;
- this.httpVersionMinor = 0;
- this.headers = {};
- this.trailers = {};
- this.req = null;
-
- this.aborted = false;
- this.complete = false;
- this.upgrade = null;
-
- this.rawHeaders = [];
- this.rawTrailers = [];
-
- this.socket = socket;
-
- this._dumped = false;
- }
-
- get connection() {
- return this.socket;
- }
-
- set connection(value) {
- this.socket = value;
- }
-
- _destroy(error, callback) {
- if (!this.readableEnded) {
- this.aborted = true;
- }
-
- // See https://github.com/nodejs/node/issues/35303
- callback();
-
- this.req._request.destroy(error);
- }
-
- setTimeout(ms, callback) {
- this.req.setTimeout(ms, callback);
- return this;
- }
-
- _dump() {
- if (!this._dumped) {
- this._dumped = true;
-
- this.removeAllListeners('data');
- this.resume();
- }
- }
-
- _read() {
- if (this.req) {
- this.req._request.resume();
- }
- }
-}
-
-module.exports = IncomingMessage;