diff options
author | RaindropsSys <contact@minteck.org> | 2023-04-06 22:18:28 +0200 |
---|---|---|
committer | RaindropsSys <contact@minteck.org> | 2023-04-06 22:18:28 +0200 |
commit | 83354b2b88218090988dd6e526b0a2505b57e0f1 (patch) | |
tree | e3c73c38a122a78bb7e66fbb99056407edd9d4b9 /includes/external/addressbook/node_modules/htmlparser2/lib/WritableStream.js | |
parent | 47b8f2299a483024c4a6a8876af825a010954caa (diff) | |
download | pluralconnect-83354b2b88218090988dd6e526b0a2505b57e0f1.tar.gz pluralconnect-83354b2b88218090988dd6e526b0a2505b57e0f1.tar.bz2 pluralconnect-83354b2b88218090988dd6e526b0a2505b57e0f1.zip |
Updated 5 files and added 1110 files (automated)
Diffstat (limited to 'includes/external/addressbook/node_modules/htmlparser2/lib/WritableStream.js')
-rw-r--r-- | includes/external/addressbook/node_modules/htmlparser2/lib/WritableStream.js | 54 |
1 files changed, 54 insertions, 0 deletions
diff --git a/includes/external/addressbook/node_modules/htmlparser2/lib/WritableStream.js b/includes/external/addressbook/node_modules/htmlparser2/lib/WritableStream.js new file mode 100644 index 0000000..3614c31 --- /dev/null +++ b/includes/external/addressbook/node_modules/htmlparser2/lib/WritableStream.js @@ -0,0 +1,54 @@ +"use strict"; +var __extends = (this && this.__extends) || (function () { + var extendStatics = function (d, b) { + extendStatics = Object.setPrototypeOf || + ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) || + function (d, b) { for (var p in b) if (Object.prototype.hasOwnProperty.call(b, p)) d[p] = b[p]; }; + return extendStatics(d, b); + }; + return function (d, b) { + if (typeof b !== "function" && b !== null) + throw new TypeError("Class extends value " + String(b) + " is not a constructor or null"); + extendStatics(d, b); + function __() { this.constructor = d; } + d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __()); + }; +})(); +Object.defineProperty(exports, "__esModule", { value: true }); +exports.WritableStream = void 0; +var Parser_js_1 = require("./Parser.js"); +/* + * NOTE: If either of these two imports produces a type error, + * please update your @types/node dependency! + */ +var node_stream_1 = require("node:stream"); +var node_string_decoder_1 = require("node:string_decoder"); +// Following the example in https://nodejs.org/api/stream.html#stream_decoding_buffers_in_a_writable_stream +function isBuffer(_chunk, encoding) { + return encoding === "buffer"; +} +/** + * WritableStream makes the `Parser` interface available as a NodeJS stream. + * + * @see Parser + */ +var WritableStream = /** @class */ (function (_super) { + __extends(WritableStream, _super); + function WritableStream(cbs, options) { + var _this = _super.call(this, { decodeStrings: false }) || this; + _this._decoder = new node_string_decoder_1.StringDecoder(); + _this._parser = new Parser_js_1.Parser(cbs, options); + return _this; + } + WritableStream.prototype._write = function (chunk, encoding, callback) { + this._parser.write(isBuffer(chunk, encoding) ? this._decoder.write(chunk) : chunk); + callback(); + }; + WritableStream.prototype._final = function (callback) { + this._parser.end(this._decoder.end()); + callback(); + }; + return WritableStream; +}(node_stream_1.Writable)); +exports.WritableStream = WritableStream; +//# sourceMappingURL=WritableStream.js.map
\ No newline at end of file |