From 0571ad9abec2c24fe476b6956942977735027b37 Mon Sep 17 00:00:00 2001 From: Pieter Heyvaert Date: Tue, 30 Oct 2018 16:15:05 +0100 Subject: [PATCH] separate query for firstmove --- .gitignore | 1 + dist/main.js | 32 ++++++++++++++++---------------- lib/semanticchess.js | 19 ++++++++++++------- package-lock.json | 41 ++++++++++++++++++++++++++++------------- 4 files changed, 57 insertions(+), 36 deletions(-) diff --git a/.gitignore b/.gitignore index fd4f2b0..ef45b97 100644 --- a/.gitignore +++ b/.gitignore @@ -1,2 +1,3 @@ node_modules .DS_Store +.idea \ No newline at end of file diff --git a/dist/main.js b/dist/main.js index fd9cd2d..605cefe 100644 --- a/dist/main.js +++ b/dist/main.js @@ -126,7 +126,7 @@ eval("const auth = __webpack_require__(/*! solid-auth-client */ \"./node_modules /*! no static exports found */ /***/ (function(module, exports, __webpack_require__) { -eval("const chessOnto = 'http://purl.org/NET/rdfchess/ontology/';\nconst xsd = 'http://www.w3.org/2001/XMLSchema#';\nconst rdf = 'http://www.w3.org/1999/02/22-rdf-syntax-ns#';\nconst uniqid = __webpack_require__(/*! uniqid */ \"./node_modules/uniqid/index.js\");\nconst N3 = __webpack_require__(/*! n3 */ \"./node_modules/n3/N3.js\");\nconst { DataFactory } = N3;\nconst { namedNode, literal, defaultGraph, quad } = DataFactory;\nconst newEngine = __webpack_require__(/*! @comunica/actor-init-sparql-rdfjs */ \"./node_modules/@comunica/actor-init-sparql-rdfjs/index-browser.js\").newEngine;\nconst auth = __webpack_require__(/*! solid-auth-client */ \"./node_modules/solid-auth-client/lib/index.js\");\n\nclass SemanticChessGame {\n\n /*\n @url the unique url of this chess game\n @userDataURL the url of the current user's data file where the chess data is stored\n @userWebId the WebID of the current user\n @opponentWebId the WebID of the opponent\n */\n constructor(url, userDataURL, userWebId, opponentWebId = null, colorOfUser = 'white') {\n this.url = url;\n this.userDataURL = userDataURL;\n this.userWebId = userWebId;\n this.opponentWebId = opponentWebId;\n this.colorOfUser = colorOfUser;\n this.turn = colorOfUser;\n\n if (this.colorOfUser === 'white') {\n this.colorOfOpponent = 'black';\n } else {\n this.colorOfOpponent = 'white';\n }\n\n this.lastMove = null;\n this.lastUserMove = null;\n }\n\n addMove(san) {\n let sparqlQuery;\n\n if (this.turn === this.colorOfUser) {\n sparqlQuery = this._addUserMove(san);\n this.turn = 'black';\n } else {\n sparqlQuery = this._addOpponentMove(san);\n this.turn = 'white';\n }\n\n return sparqlQuery;\n }\n\n getLastUserMove() {\n return this.lastUserMove;\n }\n\n getUserColor() {\n return this.colorOfUser;\n }\n\n getOpponentColor() {\n return this.colorOfOpponent;\n }\n\n /*\n Updates the last user move and returns the corresponding RDF\n */\n _addUserMove(san) {\n //generate URL for move\n const moveURL = this.userDataURL + `#` + uniqid();\n\n let sparqlUpdate = 'INSERT DATA {\\n';\n\n sparqlUpdate +=\n `<${this.url}> <${chessOnto}hasHalfMove> <${moveURL}>.\n\n <${moveURL}> <${rdf}type> <${chessOnto}HalfMove>;\n <${chessOnto}hasSANRecord> \"${san}\"^^<${xsd}string>.\\n`;\n\n if (this.lastMove) {\n sparqlUpdate += `<${this.lastMove.url}> <${chessOnto}nextHalfMove> <${moveURL}>.\\n`;\n } else {\n sparqlUpdate += `<${this.url}> <${chessOnto}hasFirstHalfMove> <${moveURL}>.\\n`;\n }\n\n sparqlUpdate += `}`;\n\n this.lastMove = {\n url: moveURL,\n san\n };\n\n this.lastUserMove = this.lastMove;\n\n return sparqlUpdate;\n }\n\n _addOpponentMove(moveUrl, san) {\n\n }\n\n getGameRDF() {\n if (!this.gameRDF) {\n const userAgentRole = this.userDataURL + `#` + uniqid();\n const opponentAgentRole = this.userDataURL + `#` + uniqid();\n\n this.gameRDF = `\n <${this.url}> <${rdf}type> <${chessOnto}ChessGame>;\n <${chessOnto}providesAgentRole> <${userAgentRole}>, <${opponentAgentRole}>.\n\n <${userAgentRole}> <${rdf}type> <${chessOnto}WhitePlayerRole>;\n <${chessOnto}performedBy> <${this.userWebId}>.\n\n <${opponentAgentRole}> <${rdf}type> <${chessOnto}BlackPlayerRole>;\n <${chessOnto}performedBy> <${this.opponentWebId}>.\n `;\n }\n\n return this.gameRDF;\n }\n\n /*\n Generates a hash for the current state of the chess game\n */\n _generateHash() {\n\n }\n\n static generateFromUrl(gameUrl, userWebId) {\n this.url = gameUrl;\n auth.fetch(gameUrl)\n .then(async res => {\n if (res.status === 404) {\n deferred.reject(404);\n } else {\n const body = await res.text();\n const store = N3.Store();\n const parser = N3.Parser();\n\n console.log(body);\n\n parser.parse(body, (err, quad, prefixes) => {\n if (err) {\n deferred.reject();\n } else if (quad) {\n store.addQuad(quad);\n } else {\n const firstHalfMoves = store.getQuads(namedNode(gameUrl), namedNode(chessOnto + 'hasFirstHalfMove'), null).map(a => a.object);\n\n if (firstHalfMoves.length > 0) {\n console.log(firstHalfMoves);\n }\n\n const source = {\n match: function(s, p, o, g) {\n return __webpack_require__(/*! streamify-array */ \"./node_modules/streamify-array/index.js\")(store.getQuads(s, p, o, g));\n }\n };\n\n // Create our engine, and query it.\n // If you intend to query multiple times, be sure to cache your engine for optimal performance.\n const myEngine = newEngine();\n myEngine.query(`SELECT * { ?agentRole <${rdf}type> ?playerRole;\n <${chessOnto}performedBy> <${userWebId}> } LIMIT 100`,\n { sources: [ { type: 'rdfjsSource', value: source } ] })\n .then(function (result) {\n result.bindingsStream.on('data', function (data) {\n // Each data object contains a mapping from variables to RDFJS terms.\n console.log(data);\n });\n });\n }\n });\n }\n });\n }\n}\n\nmodule.exports = SemanticChessGame;\n\n\n//# sourceURL=webpack:///./lib/semanticchess.js?"); +eval("const chessOnto = 'http://purl.org/NET/rdfchess/ontology/';\nconst xsd = 'http://www.w3.org/2001/XMLSchema#';\nconst rdf = 'http://www.w3.org/1999/02/22-rdf-syntax-ns#';\nconst uniqid = __webpack_require__(/*! uniqid */ \"./node_modules/uniqid/index.js\");\nconst N3 = __webpack_require__(/*! n3 */ \"./node_modules/n3/N3.js\");\nconst { DataFactory } = N3;\nconst { namedNode, literal, defaultGraph, quad } = DataFactory;\nconst newEngine = __webpack_require__(/*! @comunica/actor-init-sparql-rdfjs */ \"./node_modules/@comunica/actor-init-sparql-rdfjs/index-browser.js\").newEngine;\nconst auth = __webpack_require__(/*! solid-auth-client */ \"./node_modules/solid-auth-client/lib/index.js\");\n\nclass SemanticChessGame {\n\n /*\n @url the unique url of this chess game\n @userDataURL the url of the current user's data file where the chess data is stored\n @userWebId the WebID of the current user\n @opponentWebId the WebID of the opponent\n */\n constructor(url, userDataURL, userWebId, opponentWebId = null, colorOfUser = 'white') {\n this.url = url;\n this.userDataURL = userDataURL;\n this.userWebId = userWebId;\n this.opponentWebId = opponentWebId;\n this.colorOfUser = colorOfUser;\n this.turn = colorOfUser;\n\n if (this.colorOfUser === 'white') {\n this.colorOfOpponent = 'black';\n } else {\n this.colorOfOpponent = 'white';\n }\n\n this.lastMove = null;\n this.lastUserMove = null;\n }\n\n addMove(san) {\n let sparqlQuery;\n\n if (this.turn === this.colorOfUser) {\n sparqlQuery = this._addUserMove(san);\n this.turn = 'black';\n } else {\n sparqlQuery = this._addOpponentMove(san);\n this.turn = 'white';\n }\n\n return sparqlQuery;\n }\n\n getLastUserMove() {\n return this.lastUserMove;\n }\n\n getUserColor() {\n return this.colorOfUser;\n }\n\n getOpponentColor() {\n return this.colorOfOpponent;\n }\n\n /*\n Updates the last user move and returns the corresponding RDF\n */\n _addUserMove(san) {\n //generate URL for move\n const moveURL = this.userDataURL + `#` + uniqid();\n\n let sparqlUpdate = 'INSERT DATA {\\n';\n\n sparqlUpdate +=\n `<${this.url}> <${chessOnto}hasHalfMove> <${moveURL}>.\n\n <${moveURL}> <${rdf}type> <${chessOnto}HalfMove>;\n <${chessOnto}hasSANRecord> \"${san}\"^^<${xsd}string>.\\n`;\n\n if (this.lastMove) {\n sparqlUpdate += `<${this.lastMove.url}> <${chessOnto}nextHalfMove> <${moveURL}>.\\n`;\n } else {\n sparqlUpdate += `<${this.url}> <${chessOnto}hasFirstHalfMove> <${moveURL}>.\\n`;\n }\n\n sparqlUpdate += `}`;\n\n this.lastMove = {\n url: moveURL,\n san\n };\n\n this.lastUserMove = this.lastMove;\n\n return sparqlUpdate;\n }\n\n _addOpponentMove(moveUrl, san) {\n\n }\n\n getGameRDF() {\n if (!this.gameRDF) {\n const userAgentRole = this.userDataURL + `#` + uniqid();\n const opponentAgentRole = this.userDataURL + `#` + uniqid();\n\n this.gameRDF = `\n <${this.url}> <${rdf}type> <${chessOnto}ChessGame>;\n <${chessOnto}providesAgentRole> <${userAgentRole}>, <${opponentAgentRole}>.\n\n <${userAgentRole}> <${rdf}type> <${chessOnto}WhitePlayerRole>;\n <${chessOnto}performedBy> <${this.userWebId}>.\n\n <${opponentAgentRole}> <${rdf}type> <${chessOnto}BlackPlayerRole>;\n <${chessOnto}performedBy> <${this.opponentWebId}>.\n `;\n }\n\n return this.gameRDF;\n }\n\n /*\n Generates a hash for the current state of the chess game\n */\n _generateHash() {\n\n }\n\n static generateFromUrl(gameUrl, userWebId) {\n this.url = gameUrl;\n\n auth.fetch(gameUrl)\n .then(async res => {\n if (res.status === 404) {\n deferred.reject(404);\n } else {\n const body = await res.text();\n const store = N3.Store();\n const parser = N3.Parser();\n\n console.log(body);\n\n parser.parse(body, (err, quad, prefixes) => {\n if (err) {\n deferred.reject();\n } else if (quad) {\n store.addQuad(quad);\n } else {\n const source = {\n match: function(s, p, o, g) {\n return __webpack_require__(/*! streamify-array */ \"./node_modules/streamify-array/index.js\")(store.getQuads(s, p, o, g));\n }\n };\n const myEngine = newEngine();\n\n myEngine.query(`SELECT * { <${gameUrl}> ?p ?firstMove.\n } LIMIT 100`,\n { sources: [ { type: 'rdfjsSource', value: source } ] })\n .then(function (result) {\n result.bindingsStream.on('data', function (data) {\n // Each data object contains a mapping from variables to RDFJS terms.\n console.log(data);\n });\n });\n\n // Create our engine, and query it.\n // If you intend to query multiple times, be sure to cache your engine for optimal performance.\n myEngine.query(`SELECT * { ?agentRole <${rdf}type> ?playerRole;\n <${chessOnto}performedBy> <${userWebId}> } LIMIT 100`,\n { sources: [ { type: 'rdfjsSource', value: source } ] })\n .then(function (result) {\n result.bindingsStream.on('data', function (data) {\n // Each data object contains a mapping from variables to RDFJS terms.\n console.log(data);\n });\n });\n }\n });\n }\n });\n }\n}\n\nmodule.exports = SemanticChessGame;\n\n\n//# sourceURL=webpack:///./lib/semanticchess.js?"); /***/ }), @@ -4392,10 +4392,10 @@ eval("\n\nvar utils = exports;\nvar BN = __webpack_require__(/*! bn.js */ \"./no /*!********************************************!*\ !*** ./node_modules/elliptic/package.json ***! \********************************************/ -/*! exports provided: _from, _id, _inBundle, _integrity, _location, _phantomChildren, _requested, _requiredBy, _resolved, _shasum, _spec, _where, author, bugs, bundleDependencies, dependencies, deprecated, description, devDependencies, files, homepage, keywords, license, main, name, repository, scripts, version, default */ +/*! exports provided: _args, _from, _id, _inBundle, _integrity, _location, _phantomChildren, _requested, _requiredBy, _resolved, _spec, _where, author, bugs, dependencies, description, devDependencies, files, homepage, keywords, license, main, name, repository, scripts, version, default */ /***/ (function(module) { -eval("module.exports = {\"_from\":\"elliptic@^6.0.0\",\"_id\":\"elliptic@6.4.1\",\"_inBundle\":false,\"_integrity\":\"sha512-BsXLz5sqX8OHcsh7CqBMztyXARmGQ3LWPtGjJi6DiJHq5C/qvi9P3OqgswKSDftbu8+IoI/QDTAm2fFnQ9SZSQ==\",\"_location\":\"/elliptic\",\"_phantomChildren\":{},\"_requested\":{\"type\":\"range\",\"registry\":true,\"raw\":\"elliptic@^6.0.0\",\"name\":\"elliptic\",\"escapedName\":\"elliptic\",\"rawSpec\":\"^6.0.0\",\"saveSpec\":null,\"fetchSpec\":\"^6.0.0\"},\"_requiredBy\":[\"/browserify-sign\",\"/create-ecdh\"],\"_resolved\":\"https://registry.npmjs.org/elliptic/-/elliptic-6.4.1.tgz\",\"_shasum\":\"c2d0b7776911b86722c632c3c06c60f2f819939a\",\"_spec\":\"elliptic@^6.0.0\",\"_where\":\"/Users/pieter/Developer/solid-chess/node_modules/browserify-sign\",\"author\":{\"name\":\"Fedor Indutny\",\"email\":\"fedor@indutny.com\"},\"bugs\":{\"url\":\"https://github.com/indutny/elliptic/issues\"},\"bundleDependencies\":false,\"dependencies\":{\"bn.js\":\"^4.4.0\",\"brorand\":\"^1.0.1\",\"hash.js\":\"^1.0.0\",\"hmac-drbg\":\"^1.0.0\",\"inherits\":\"^2.0.1\",\"minimalistic-assert\":\"^1.0.0\",\"minimalistic-crypto-utils\":\"^1.0.0\"},\"deprecated\":false,\"description\":\"EC cryptography\",\"devDependencies\":{\"brfs\":\"^1.4.3\",\"coveralls\":\"^2.11.3\",\"grunt\":\"^0.4.5\",\"grunt-browserify\":\"^5.0.0\",\"grunt-cli\":\"^1.2.0\",\"grunt-contrib-connect\":\"^1.0.0\",\"grunt-contrib-copy\":\"^1.0.0\",\"grunt-contrib-uglify\":\"^1.0.1\",\"grunt-mocha-istanbul\":\"^3.0.1\",\"grunt-saucelabs\":\"^8.6.2\",\"istanbul\":\"^0.4.2\",\"jscs\":\"^2.9.0\",\"jshint\":\"^2.6.0\",\"mocha\":\"^2.1.0\"},\"files\":[\"lib\"],\"homepage\":\"https://github.com/indutny/elliptic\",\"keywords\":[\"EC\",\"Elliptic\",\"curve\",\"Cryptography\"],\"license\":\"MIT\",\"main\":\"lib/elliptic.js\",\"name\":\"elliptic\",\"repository\":{\"type\":\"git\",\"url\":\"git+ssh://git@github.com/indutny/elliptic.git\"},\"scripts\":{\"jscs\":\"jscs benchmarks/*.js lib/*.js lib/**/*.js lib/**/**/*.js test/index.js\",\"jshint\":\"jscs benchmarks/*.js lib/*.js lib/**/*.js lib/**/**/*.js test/index.js\",\"lint\":\"npm run jscs && npm run jshint\",\"test\":\"npm run lint && npm run unit\",\"unit\":\"istanbul test _mocha --reporter=spec test/index.js\",\"version\":\"grunt dist && git add dist/\"},\"version\":\"6.4.1\"};\n\n//# sourceURL=webpack:///./node_modules/elliptic/package.json?"); +eval("module.exports = {\"_args\":[[\"elliptic@6.4.1\",\"/home/pieter/Developer/solid-chess\"]],\"_from\":\"elliptic@6.4.1\",\"_id\":\"elliptic@6.4.1\",\"_inBundle\":false,\"_integrity\":\"sha512-BsXLz5sqX8OHcsh7CqBMztyXARmGQ3LWPtGjJi6DiJHq5C/qvi9P3OqgswKSDftbu8+IoI/QDTAm2fFnQ9SZSQ==\",\"_location\":\"/elliptic\",\"_phantomChildren\":{},\"_requested\":{\"type\":\"version\",\"registry\":true,\"raw\":\"elliptic@6.4.1\",\"name\":\"elliptic\",\"escapedName\":\"elliptic\",\"rawSpec\":\"6.4.1\",\"saveSpec\":null,\"fetchSpec\":\"6.4.1\"},\"_requiredBy\":[\"/@trust/keyto\",\"/@trust/webcrypto\",\"/browserify-sign\",\"/create-ecdh\"],\"_resolved\":\"https://registry.npmjs.org/elliptic/-/elliptic-6.4.1.tgz\",\"_spec\":\"6.4.1\",\"_where\":\"/home/pieter/Developer/solid-chess\",\"author\":{\"name\":\"Fedor Indutny\",\"email\":\"fedor@indutny.com\"},\"bugs\":{\"url\":\"https://github.com/indutny/elliptic/issues\"},\"dependencies\":{\"bn.js\":\"^4.4.0\",\"brorand\":\"^1.0.1\",\"hash.js\":\"^1.0.0\",\"hmac-drbg\":\"^1.0.0\",\"inherits\":\"^2.0.1\",\"minimalistic-assert\":\"^1.0.0\",\"minimalistic-crypto-utils\":\"^1.0.0\"},\"description\":\"EC cryptography\",\"devDependencies\":{\"brfs\":\"^1.4.3\",\"coveralls\":\"^2.11.3\",\"grunt\":\"^0.4.5\",\"grunt-browserify\":\"^5.0.0\",\"grunt-cli\":\"^1.2.0\",\"grunt-contrib-connect\":\"^1.0.0\",\"grunt-contrib-copy\":\"^1.0.0\",\"grunt-contrib-uglify\":\"^1.0.1\",\"grunt-mocha-istanbul\":\"^3.0.1\",\"grunt-saucelabs\":\"^8.6.2\",\"istanbul\":\"^0.4.2\",\"jscs\":\"^2.9.0\",\"jshint\":\"^2.6.0\",\"mocha\":\"^2.1.0\"},\"files\":[\"lib\"],\"homepage\":\"https://github.com/indutny/elliptic\",\"keywords\":[\"EC\",\"Elliptic\",\"curve\",\"Cryptography\"],\"license\":\"MIT\",\"main\":\"lib/elliptic.js\",\"name\":\"elliptic\",\"repository\":{\"type\":\"git\",\"url\":\"git+ssh://git@github.com/indutny/elliptic.git\"},\"scripts\":{\"jscs\":\"jscs benchmarks/*.js lib/*.js lib/**/*.js lib/**/**/*.js test/index.js\",\"jshint\":\"jscs benchmarks/*.js lib/*.js lib/**/*.js lib/**/**/*.js test/index.js\",\"lint\":\"npm run jscs && npm run jshint\",\"test\":\"npm run lint && npm run unit\",\"unit\":\"istanbul test _mocha --reporter=spec test/index.js\",\"version\":\"grunt dist && git add dist/\"},\"version\":\"6.4.1\"};\n\n//# sourceURL=webpack:///./node_modules/elliptic/package.json?"); /***/ }), @@ -6796,7 +6796,7 @@ eval("/* WEBPACK VAR INJECTION */(function(module, global) {var __WEBPACK_AMD_DE /***/ (function(module, exports, __webpack_require__) { "use strict"; -eval("/* WEBPACK VAR INJECTION */(function(Buffer) {\nconst nodeStream = __webpack_require__(/*! stream */ \"./node_modules/stream-browserify/index.js\");\nconst isNodeStream = __webpack_require__(/*! is-stream */ \"./node_modules/is-stream/index.js\");\nconst conversions = __webpack_require__(/*! ./lib/conversions */ \"./node_modules/node-web-streams/lib/conversions.js\");\n\nmodule.exports = __webpack_require__(/*! web-streams-polyfill */ \"./node_modules/web-streams-polyfill/dist/polyfill.min.js\");\n\n/**\n * Convert Web streams to Node streams. Until WritableStream / TransformStream\n * is finalized, only ReadableStream is supported.\n *\n * @param {ReadableStream} stream, a web stream.\n * @return {stream.Readable}, a Node Readable stream.\n */\nmodule.exports.toNodeReadable = function(stream) {\n if (stream instanceof module.exports.ReadableStream\n || stream && typeof stream.getReader === 'function') {\n return conversions.readable.webToNode(stream);\n } else {\n throw new TypeError(\"Expected a ReadableStream.\");\n }\n};\n\n/**\n * Convert Node Readable streams, an Array, Buffer or String to a Web\n * ReadableStream.\n *\n * @param {Readable|Array|Buffer|String} stream, a Node Readable stream,\n * Array, Buffer or String.\n * @return {ReadableStream}, a web ReadableStream.\n */\nmodule.exports.toWebReadableStream = function(stream) {\n if (isNodeStream(stream) && stream.readable) {\n return conversions.readable.nodeToWeb(stream);\n } else if (Array.isArray(stream)) {\n return conversions.readable.arrayToWeb(stream);\n } else if (Buffer.isBuffer(stream) || typeof stream === 'string') {\n return conversions.readable.arrayToWeb([stream]);\n } else {\n throw new TypeError(\"Expected a Node streams.Readable, an Array, Buffer or String.\");\n }\n};\n\n/* WEBPACK VAR INJECTION */}.call(this, __webpack_require__(/*! ./../buffer/index.js */ \"./node_modules/buffer/index.js\").Buffer))\n\n//# sourceURL=webpack:///./node_modules/node-web-streams/index.js?"); +eval("/* WEBPACK VAR INJECTION */(function(Buffer) {\nconst nodeStream = __webpack_require__(/*! stream */ \"./node_modules/stream-browserify/index.js\");\nconst isNodeStream = __webpack_require__(/*! is-stream */ \"./node_modules/is-stream/index.js\");\nconst conversions = __webpack_require__(/*! ./lib/conversions */ \"./node_modules/node-web-streams/lib/conversions.js\");\n\nmodule.exports = __webpack_require__(/*! web-streams-polyfill */ \"./node_modules/node-web-streams/node_modules/web-streams-polyfill/dist/polyfill.min.js\");\n\n/**\n * Convert Web streams to Node streams. Until WritableStream / TransformStream\n * is finalized, only ReadableStream is supported.\n *\n * @param {ReadableStream} stream, a web stream.\n * @return {stream.Readable}, a Node Readable stream.\n */\nmodule.exports.toNodeReadable = function(stream) {\n if (stream instanceof module.exports.ReadableStream\n || stream && typeof stream.getReader === 'function') {\n return conversions.readable.webToNode(stream);\n } else {\n throw new TypeError(\"Expected a ReadableStream.\");\n }\n};\n\n/**\n * Convert Node Readable streams, an Array, Buffer or String to a Web\n * ReadableStream.\n *\n * @param {Readable|Array|Buffer|String} stream, a Node Readable stream,\n * Array, Buffer or String.\n * @return {ReadableStream}, a web ReadableStream.\n */\nmodule.exports.toWebReadableStream = function(stream) {\n if (isNodeStream(stream) && stream.readable) {\n return conversions.readable.nodeToWeb(stream);\n } else if (Array.isArray(stream)) {\n return conversions.readable.arrayToWeb(stream);\n } else if (Buffer.isBuffer(stream) || typeof stream === 'string') {\n return conversions.readable.arrayToWeb([stream]);\n } else {\n throw new TypeError(\"Expected a Node streams.Readable, an Array, Buffer or String.\");\n }\n};\n\n/* WEBPACK VAR INJECTION */}.call(this, __webpack_require__(/*! ./../buffer/index.js */ \"./node_modules/buffer/index.js\").Buffer))\n\n//# sourceURL=webpack:///./node_modules/node-web-streams/index.js?"); /***/ }), @@ -6808,7 +6808,18 @@ eval("/* WEBPACK VAR INJECTION */(function(Buffer) {\nconst nodeStream = __webpa /***/ (function(module, exports, __webpack_require__) { "use strict"; -eval("\n\nconst Readable = __webpack_require__(/*! stream */ \"./node_modules/stream-browserify/index.js\").Readable;\nconst ReadableStream = __webpack_require__(/*! web-streams-polyfill */ \"./node_modules/web-streams-polyfill/dist/polyfill.min.js\").ReadableStream;\n\n/**\n * Web / node stream conversion functions\n */\n\nfunction readableNodeToWeb(nodeStream) {\n return new ReadableStream({\n start(controller) {\n nodeStream.pause();\n nodeStream.on('data', chunk => {\n controller.enqueue(chunk);\n nodeStream.pause();\n });\n nodeStream.on('end', () => controller.close());\n nodeStream.on('error', (e) => controller.error(e));\n },\n pull(controller) {\n nodeStream.resume();\n },\n cancel(reason) {\n nodeStream.pause();\n }\n });\n}\n\n/**\n * ReadableStream wrapping an array.\n *\n * @param {Array} arr, the array to wrap into a stream.\n * @return {ReadableStream}\n */\nfunction arrayToWeb(arr) {\n return new ReadableStream({\n start(controller) {\n for (var i = 0; i < arr.length; i++) {\n controller.enqueue(arr[i]);\n }\n controller.close();\n }\n });\n}\n\n\nclass NodeReadable extends Readable {\n constructor(webStream, options) {\n super(options);\n this._webStream = webStream;\n this._reader = webStream.getReader();\n this._reading = false;\n }\n\n _read(size) {\n if (this._reading) {\n return;\n }\n this._reading = true;\n const doRead = () => {\n this._reader.read()\n .then(res => {\n if (res.done) {\n this.push(null);\n return;\n }\n if (this.push(res.value)) {\n return doRead(size);\n } else {\n this._reading = false;\n }\n });\n };\n doRead();\n }\n}\n\nfunction readableWebToNode(webStream) {\n return new NodeReadable(webStream);\n}\n\nmodule.exports = {\n readable: {\n nodeToWeb: readableNodeToWeb,\n arrayToWeb: arrayToWeb,\n webToNode: readableWebToNode,\n },\n};\n\n// Simple round-trip test.\n// let nodeReader = require('fs').createReadStream('/tmp/test.txt');\n// let webReader = readableNodeToWeb(nodeReader);\n// let roundTrippedReader = readableWebToNode(webReader);\n// roundTrippedReader.pipe(process.stdout);\n\n\n//# sourceURL=webpack:///./node_modules/node-web-streams/lib/conversions.js?"); +eval("\n\nconst Readable = __webpack_require__(/*! stream */ \"./node_modules/stream-browserify/index.js\").Readable;\nconst ReadableStream = __webpack_require__(/*! web-streams-polyfill */ \"./node_modules/node-web-streams/node_modules/web-streams-polyfill/dist/polyfill.min.js\").ReadableStream;\n\n/**\n * Web / node stream conversion functions\n */\n\nfunction readableNodeToWeb(nodeStream) {\n return new ReadableStream({\n start(controller) {\n nodeStream.pause();\n nodeStream.on('data', chunk => {\n controller.enqueue(chunk);\n nodeStream.pause();\n });\n nodeStream.on('end', () => controller.close());\n nodeStream.on('error', (e) => controller.error(e));\n },\n pull(controller) {\n nodeStream.resume();\n },\n cancel(reason) {\n nodeStream.pause();\n }\n });\n}\n\n/**\n * ReadableStream wrapping an array.\n *\n * @param {Array} arr, the array to wrap into a stream.\n * @return {ReadableStream}\n */\nfunction arrayToWeb(arr) {\n return new ReadableStream({\n start(controller) {\n for (var i = 0; i < arr.length; i++) {\n controller.enqueue(arr[i]);\n }\n controller.close();\n }\n });\n}\n\n\nclass NodeReadable extends Readable {\n constructor(webStream, options) {\n super(options);\n this._webStream = webStream;\n this._reader = webStream.getReader();\n this._reading = false;\n }\n\n _read(size) {\n if (this._reading) {\n return;\n }\n this._reading = true;\n const doRead = () => {\n this._reader.read()\n .then(res => {\n if (res.done) {\n this.push(null);\n return;\n }\n if (this.push(res.value)) {\n return doRead(size);\n } else {\n this._reading = false;\n }\n });\n };\n doRead();\n }\n}\n\nfunction readableWebToNode(webStream) {\n return new NodeReadable(webStream);\n}\n\nmodule.exports = {\n readable: {\n nodeToWeb: readableNodeToWeb,\n arrayToWeb: arrayToWeb,\n webToNode: readableWebToNode,\n },\n};\n\n// Simple round-trip test.\n// let nodeReader = require('fs').createReadStream('/tmp/test.txt');\n// let webReader = readableNodeToWeb(nodeReader);\n// let roundTrippedReader = readableWebToNode(webReader);\n// roundTrippedReader.pipe(process.stdout);\n\n\n//# sourceURL=webpack:///./node_modules/node-web-streams/lib/conversions.js?"); + +/***/ }), + +/***/ "./node_modules/node-web-streams/node_modules/web-streams-polyfill/dist/polyfill.min.js": +/*!**********************************************************************************************!*\ + !*** ./node_modules/node-web-streams/node_modules/web-streams-polyfill/dist/polyfill.min.js ***! + \**********************************************************************************************/ +/*! no static exports found */ +/***/ (function(module, exports, __webpack_require__) { + +eval("/* WEBPACK VAR INJECTION */(function(global) {var require;var require;!function(f){if(true)module.exports=f();else { var g; }}(function(){return function e(t,n,r){function s(o,u){if(!n[o]){if(!t[o]){var a=\"function\"==typeof require&&require;if(!u&&a)return require(o,!0);if(i)return i(o,!0);var f=new Error(\"Cannot find module '\"+o+\"'\");throw f.code=\"MODULE_NOT_FOUND\",f}var l=n[o]={exports:{}};t[o][0].call(l.exports,function(e){var n=t[o][1][e];return s(n?n:e)},l,l.exports,e,t,n,r)}return n[o].exports}for(var i=\"function\"==typeof require&&require,o=0;o=0;i--)if(ka[i]!=kb[i])return!1;for(i=ka.length-1;i>=0;i--)if(key=ka[i],!_deepEqual(a[key],b[key]))return!1;return!0}function expectedException(actual,expected){return!(!actual||!expected)&&(\"[object RegExp]\"==Object.prototype.toString.call(expected)?expected.test(actual):actual instanceof expected||expected.call({},actual)===!0)}function _throws(shouldThrow,block,expected,message){var actual;util.isString(expected)&&(message=expected,expected=null);try{block()}catch(e){actual=e}if(message=(expected&&expected.name?\" (\"+expected.name+\").\":\".\")+(message?\" \"+message:\".\"),shouldThrow&&!actual&&fail(actual,expected,\"Missing expected exception\"+message),!shouldThrow&&expectedException(actual,expected)&&fail(actual,expected,\"Got unwanted exception\"+message),shouldThrow&&actual&&expected&&!expectedException(actual,expected)||!shouldThrow&&actual)throw actual}var util=require(\"util/\"),pSlice=Array.prototype.slice,hasOwn=Object.prototype.hasOwnProperty,assert=module.exports=ok;assert.AssertionError=function(options){this.name=\"AssertionError\",this.actual=options.actual,this.expected=options.expected,this.operator=options.operator,options.message?(this.message=options.message,this.generatedMessage=!1):(this.message=getMessage(this),this.generatedMessage=!0);var stackStartFunction=options.stackStartFunction||fail;if(Error.captureStackTrace)Error.captureStackTrace(this,stackStartFunction);else{var err=new Error;if(err.stack){var out=err.stack,fn_name=stackStartFunction.name,idx=out.indexOf(\"\\n\"+fn_name);if(idx>=0){var next_line=out.indexOf(\"\\n\",idx+1);out=out.substring(next_line+1)}this.stack=out}}},util.inherits(assert.AssertionError,Error),assert.fail=fail,assert.ok=ok,assert.equal=function(actual,expected,message){actual!=expected&&fail(actual,expected,message,\"==\",assert.equal)},assert.notEqual=function(actual,expected,message){actual==expected&&fail(actual,expected,message,\"!=\",assert.notEqual)},assert.deepEqual=function(actual,expected,message){_deepEqual(actual,expected)||fail(actual,expected,message,\"deepEqual\",assert.deepEqual)},assert.notDeepEqual=function(actual,expected,message){_deepEqual(actual,expected)&&fail(actual,expected,message,\"notDeepEqual\",assert.notDeepEqual)},assert.strictEqual=function(actual,expected,message){actual!==expected&&fail(actual,expected,message,\"===\",assert.strictEqual)},assert.notStrictEqual=function(actual,expected,message){actual===expected&&fail(actual,expected,message,\"!==\",assert.notStrictEqual)},assert.throws=function(block,error,message){_throws.apply(this,[!0].concat(pSlice.call(arguments)))},assert.doesNotThrow=function(block,message){_throws.apply(this,[!1].concat(pSlice.call(arguments)))},assert.ifError=function(err){if(err)throw err};var objectKeys=Object.keys||function(obj){var keys=[];for(var key in obj)hasOwn.call(obj,key)&&keys.push(key);return keys}},{\"util/\":6}],3:[function(require,module,exports){\"function\"==typeof Object.create?module.exports=function(ctor,superCtor){ctor.super_=superCtor,ctor.prototype=Object.create(superCtor.prototype,{constructor:{value:ctor,enumerable:!1,writable:!0,configurable:!0}})}:module.exports=function(ctor,superCtor){ctor.super_=superCtor;var TempCtor=function(){};TempCtor.prototype=superCtor.prototype,ctor.prototype=new TempCtor,ctor.prototype.constructor=ctor}},{}],4:[function(require,module,exports){function cleanUpNextTick(){draining&¤tQueue&&(draining=!1,currentQueue.length?queue=currentQueue.concat(queue):queueIndex=-1,queue.length&&drainQueue())}function drainQueue(){if(!draining){var timeout=cachedSetTimeout(cleanUpNextTick);draining=!0;for(var len=queue.length;len;){for(currentQueue=queue,queue=[];++queueIndex1)for(var i=1;i=3&&(ctx.depth=arguments[2]),arguments.length>=4&&(ctx.colors=arguments[3]),isBoolean(opts)?ctx.showHidden=opts:opts&&exports._extend(ctx,opts),isUndefined(ctx.showHidden)&&(ctx.showHidden=!1),isUndefined(ctx.depth)&&(ctx.depth=2),isUndefined(ctx.colors)&&(ctx.colors=!1),isUndefined(ctx.customInspect)&&(ctx.customInspect=!0),ctx.colors&&(ctx.stylize=stylizeWithColor),formatValue(ctx,obj,ctx.depth)}function stylizeWithColor(str,styleType){var style=inspect.styles[styleType];return style?\"\u001b[\"+inspect.colors[style][0]+\"m\"+str+\"\u001b[\"+inspect.colors[style][1]+\"m\":str}function stylizeNoColor(str,styleType){return str}function arrayToHash(array){var hash={};return array.forEach(function(val,idx){hash[val]=!0}),hash}function formatValue(ctx,value,recurseTimes){if(ctx.customInspect&&value&&isFunction(value.inspect)&&value.inspect!==exports.inspect&&(!value.constructor||value.constructor.prototype!==value)){var ret=value.inspect(recurseTimes,ctx);return isString(ret)||(ret=formatValue(ctx,ret,recurseTimes)),ret}var primitive=formatPrimitive(ctx,value);if(primitive)return primitive;var keys=Object.keys(value),visibleKeys=arrayToHash(keys);if(ctx.showHidden&&(keys=Object.getOwnPropertyNames(value)),isError(value)&&(keys.indexOf(\"message\")>=0||keys.indexOf(\"description\")>=0))return formatError(value);if(0===keys.length){if(isFunction(value)){var name=value.name?\": \"+value.name:\"\";return ctx.stylize(\"[Function\"+name+\"]\",\"special\")}if(isRegExp(value))return ctx.stylize(RegExp.prototype.toString.call(value),\"regexp\");if(isDate(value))return ctx.stylize(Date.prototype.toString.call(value),\"date\");if(isError(value))return formatError(value)}var base=\"\",array=!1,braces=[\"{\",\"}\"];if(isArray(value)&&(array=!0,braces=[\"[\",\"]\"]),isFunction(value)){var n=value.name?\": \"+value.name:\"\";base=\" [Function\"+n+\"]\"}if(isRegExp(value)&&(base=\" \"+RegExp.prototype.toString.call(value)),isDate(value)&&(base=\" \"+Date.prototype.toUTCString.call(value)),isError(value)&&(base=\" \"+formatError(value)),0===keys.length&&(!array||0==value.length))return braces[0]+base+braces[1];if(recurseTimes<0)return isRegExp(value)?ctx.stylize(RegExp.prototype.toString.call(value),\"regexp\"):ctx.stylize(\"[Object]\",\"special\");ctx.seen.push(value);var output;return output=array?formatArray(ctx,value,recurseTimes,visibleKeys,keys):keys.map(function(key){return formatProperty(ctx,value,recurseTimes,visibleKeys,key,array)}),ctx.seen.pop(),reduceToSingleString(output,base,braces)}function formatPrimitive(ctx,value){if(isUndefined(value))return ctx.stylize(\"undefined\",\"undefined\");if(isString(value)){var simple=\"'\"+JSON.stringify(value).replace(/^\"|\"$/g,\"\").replace(/'/g,\"\\\\'\").replace(/\\\\\"/g,'\"')+\"'\";return ctx.stylize(simple,\"string\")}return isNumber(value)?ctx.stylize(\"\"+value,\"number\"):isBoolean(value)?ctx.stylize(\"\"+value,\"boolean\"):isNull(value)?ctx.stylize(\"null\",\"null\"):void 0}function formatError(value){return\"[\"+Error.prototype.toString.call(value)+\"]\"}function formatArray(ctx,value,recurseTimes,visibleKeys,keys){for(var output=[],i=0,l=value.length;i-1&&(str=array?str.split(\"\\n\").map(function(line){return\" \"+line}).join(\"\\n\").substr(2):\"\\n\"+str.split(\"\\n\").map(function(line){return\" \"+line}).join(\"\\n\"))):str=ctx.stylize(\"[Circular]\",\"special\")),isUndefined(name)){if(array&&key.match(/^\\d+$/))return str;name=JSON.stringify(\"\"+key),name.match(/^\"([a-zA-Z_][a-zA-Z_0-9]*)\"$/)?(name=name.substr(1,name.length-2),name=ctx.stylize(name,\"name\")):(name=name.replace(/'/g,\"\\\\'\").replace(/\\\\\"/g,'\"').replace(/(^\"|\"$)/g,\"'\"),name=ctx.stylize(name,\"string\"))}return name+\": \"+str}function reduceToSingleString(output,base,braces){var numLinesEst=0,length=output.reduce(function(prev,cur){return numLinesEst++,cur.indexOf(\"\\n\")>=0&&numLinesEst++,prev+cur.replace(/\\u001b\\[\\d\\d?m/g,\"\").length+1},0);return length>60?braces[0]+(\"\"===base?\"\":base+\"\\n \")+\" \"+output.join(\",\\n \")+\" \"+braces[1]:braces[0]+base+\" \"+output.join(\", \")+\" \"+braces[1]}function isArray(ar){return Array.isArray(ar)}function isBoolean(arg){return\"boolean\"==typeof arg}function isNull(arg){return null===arg}function isNullOrUndefined(arg){return null==arg}function isNumber(arg){return\"number\"==typeof arg}function isString(arg){return\"string\"==typeof arg}function isSymbol(arg){return\"symbol\"==typeof arg}function isUndefined(arg){return void 0===arg}function isRegExp(re){return isObject(re)&&\"[object RegExp]\"===objectToString(re)}function isObject(arg){return\"object\"==typeof arg&&null!==arg}function isDate(d){return isObject(d)&&\"[object Date]\"===objectToString(d)}function isError(e){return isObject(e)&&(\"[object Error]\"===objectToString(e)||e instanceof Error)}function isFunction(arg){return\"function\"==typeof arg}function isPrimitive(arg){return null===arg||\"boolean\"==typeof arg||\"number\"==typeof arg||\"string\"==typeof arg||\"symbol\"==typeof arg||\"undefined\"==typeof arg}function objectToString(o){return Object.prototype.toString.call(o)}function pad(n){return n<10?\"0\"+n.toString(10):n.toString(10)}function timestamp(){var d=new Date,time=[pad(d.getHours()),pad(d.getMinutes()),pad(d.getSeconds())].join(\":\");return[d.getDate(),months[d.getMonth()],time].join(\" \")}function hasOwnProperty(obj,prop){return Object.prototype.hasOwnProperty.call(obj,prop)}var formatRegExp=/%[sdj%]/g;exports.format=function(f){if(!isString(f)){for(var objects=[],i=0;i=len)return x;switch(x){case\"%s\":return String(args[i++]);case\"%d\":return Number(args[i++]);case\"%j\":try{return JSON.stringify(args[i++])}catch(_){return\"[Circular]\"}default:return x}}),x=args[i];i1?_len-1:0),_key=1;_key<_len;_key++)args[_key-1]=arguments[_key];try{return Promise.resolve(func.apply(void 0,args))}catch(e){return Promise.reject(e)}},exports.typeIsObject=function(x){return\"object\"===(\"undefined\"==typeof x?\"undefined\":_typeof(x))&&null!==x||\"function\"==typeof x},exports.toInteger=function(v){return v=Number(v),isNaN(v)?0:v<0?-1*Math.floor(Math.abs(v)):Math.floor(Math.abs(v))},exports.createDataProperty=function(o,p,v){assert(exports.typeIsObject(o)),o[p]=v},exports.createArrayFromList=function(elements){return elements.slice()},exports.ArrayBufferCopy=function(dest,destOffset,src,srcOffset,n){new Uint8Array(dest).set(new Uint8Array(src,srcOffset,n),destOffset)},exports.CreateIterResultObject=function(value,done){return assert(\"boolean\"==typeof done),{value:value,done:done}},exports.IsFiniteNonNegativeNumber=function(v){return!Number.isNaN(v)&&(v!==+(1/0)&&!(v<0))},exports.InvokeOrNoop=function(O,P,args){var method=O[P];if(void 0!==method)return method.apply(O,args)},exports.PromiseInvokeOrNoop=function(O,P,args){var method=void 0;try{return method=O[P],void 0===method?Promise.resolve(void 0):Promise.resolve(method.apply(O,args))}catch(e){return Promise.reject(e)}},exports.PromiseInvokeOrFallbackOrNoop=function(O,P1,args1,P2,args2){var method=void 0;try{method=O[P1]}catch(methodE){return Promise.reject(methodE)}if(void 0===method)return exports.PromiseInvokeOrNoop(O,P2,args2);try{return Promise.resolve(method.apply(O,args1))}catch(e){return Promise.reject(e)}},exports.SameRealmTransfer=function(O){return O},exports.ValidateAndNormalizeHighWaterMark=function(highWaterMark){if(highWaterMark=Number(highWaterMark),Number.isNaN(highWaterMark)||highWaterMark<0)throw new RangeError(\"highWaterMark property of a queuing strategy must be nonnegative and non-NaN\");return highWaterMark},exports.ValidateAndNormalizeQueuingStrategy=function(size,highWaterMark){if(void 0!==size&&\"function\"!=typeof size)throw new TypeError(\"size property of a queuing strategy must be a function\");return highWaterMark=exports.ValidateAndNormalizeHighWaterMark(highWaterMark),{size:size,highWaterMark:highWaterMark}}},{assert:2}],10:[function(require,module,exports){\"use strict\";var assert=require(\"assert\"),_require=require(\"./helpers.js\"),IsFiniteNonNegativeNumber=_require.IsFiniteNonNegativeNumber;exports.DequeueValue=function(queue){assert(queue.length>0,\"Spec-level failure: should never dequeue from an empty queue.\");var pair=queue.shift();return pair.value},exports.EnqueueValueWithSize=function(queue,value,size){if(size=Number(size),!IsFiniteNonNegativeNumber(size))throw new RangeError(\"Size must be a finite, non-NaN, non-negative number.\");queue.push({value:value,size:size})},exports.GetTotalQueueSize=function(queue){var totalSize=0;return queue.forEach(function(pair){assert(\"number\"==typeof pair.size&&!Number.isNaN(pair.size)&&pair.size!==+(1/0)&&pair.size!==-(1/0),\"Spec-level failure: should never find an invalid size in the queue.\"),totalSize+=pair.size}),totalSize},exports.PeekQueueValue=function(queue){assert(queue.length>0,\"Spec-level failure: should never peek at an empty queue.\");var pair=queue[0];return pair.value}},{\"./helpers.js\":9,assert:2}],11:[function(require,module,exports){\"use strict\";function _classCallCheck(instance,Constructor){if(!(instance instanceof Constructor))throw new TypeError(\"Cannot call a class as a function\")}function AcquireReadableStreamBYOBReader(stream){return new ReadableStreamBYOBReader(stream)}function AcquireReadableStreamDefaultReader(stream){return new ReadableStreamDefaultReader(stream)}function IsReadableStream(x){return!!typeIsObject(x)&&!!Object.prototype.hasOwnProperty.call(x,\"_readableStreamController\")}function IsReadableStreamDisturbed(stream){return assert(IsReadableStream(stream)===!0,\"IsReadableStreamDisturbed should only be used on known readable streams\"),stream._disturbed}function IsReadableStreamLocked(stream){return assert(IsReadableStream(stream)===!0,\"IsReadableStreamLocked should only be used on known readable streams\"),void 0!==stream._reader}function ReadableStreamTee(stream,shouldClone){assert(IsReadableStream(stream)===!0),assert(\"boolean\"==typeof shouldClone);var reader=AcquireReadableStreamDefaultReader(stream),teeState={closedOrErrored:!1,canceled1:!1,canceled2:!1,reason1:void 0,reason2:void 0};teeState.promise=new Promise(function(resolve){return teeState._resolve=resolve});var pull=create_ReadableStreamTeePullFunction();pull._reader=reader,pull._teeState=teeState,pull._shouldClone=shouldClone;var cancel1=create_ReadableStreamTeeBranch1CancelFunction();cancel1._stream=stream,cancel1._teeState=teeState;var cancel2=create_ReadableStreamTeeBranch2CancelFunction();cancel2._stream=stream,cancel2._teeState=teeState;var underlyingSource1=Object.create(Object.prototype);createDataProperty(underlyingSource1,\"pull\",pull),createDataProperty(underlyingSource1,\"cancel\",cancel1);var branch1Stream=new ReadableStream(underlyingSource1),underlyingSource2=Object.create(Object.prototype);createDataProperty(underlyingSource2,\"pull\",pull),createDataProperty(underlyingSource2,\"cancel\",cancel2);var branch2Stream=new ReadableStream(underlyingSource2);return pull._branch1=branch1Stream._readableStreamController,pull._branch2=branch2Stream._readableStreamController,reader._closedPromise.catch(function(r){teeState.closedOrErrored!==!0&&(ReadableStreamDefaultControllerError(pull._branch1,r),ReadableStreamDefaultControllerError(pull._branch2,r),teeState.closedOrErrored=!0)}),[branch1Stream,branch2Stream]}function create_ReadableStreamTeePullFunction(){var f=function f(){var reader=f._reader,branch1=f._branch1,branch2=f._branch2,teeState=f._teeState;f._shouldClone;return ReadableStreamDefaultReaderRead(reader).then(function(result){assert(typeIsObject(result));var value=result.value,done=result.done;if(assert(\"boolean\"==typeof done),done===!0&&teeState.closedOrErrored===!1&&(teeState.canceled1===!1&&ReadableStreamDefaultControllerClose(branch1),teeState.canceled2===!1&&ReadableStreamDefaultControllerClose(branch2),teeState.closedOrErrored=!0),teeState.closedOrErrored!==!0){if(teeState.canceled1===!1){var value1=value;ReadableStreamDefaultControllerEnqueue(branch1,value1)}if(teeState.canceled2===!1){var value2=value;ReadableStreamDefaultControllerEnqueue(branch2,value2)}}})};return f}function create_ReadableStreamTeeBranch1CancelFunction(){var f=function f(reason){var stream=f._stream,teeState=f._teeState;if(teeState.canceled1=!0,teeState.reason1=reason,teeState.canceled2===!0){var compositeReason=createArrayFromList([teeState.reason1,teeState.reason2]),cancelResult=ReadableStreamCancel(stream,compositeReason);teeState._resolve(cancelResult)}return teeState.promise};return f}function create_ReadableStreamTeeBranch2CancelFunction(){var f=function f(reason){var stream=f._stream,teeState=f._teeState;if(teeState.canceled2=!0,teeState.reason2=reason,teeState.canceled1===!0){var compositeReason=createArrayFromList([teeState.reason1,teeState.reason2]),cancelResult=ReadableStreamCancel(stream,compositeReason);teeState._resolve(cancelResult)}return teeState.promise};return f}function ReadableStreamAddReadIntoRequest(stream){assert(IsReadableStreamBYOBReader(stream._reader)===!0),assert(\"readable\"===stream._state||\"closed\"===stream._state);var promise=new Promise(function(resolve,reject){var readIntoRequest={_resolve:resolve,_reject:reject};stream._reader._readIntoRequests.push(readIntoRequest)});return promise}function ReadableStreamAddReadRequest(stream){assert(IsReadableStreamDefaultReader(stream._reader)===!0),assert(\"readable\"===stream._state);var promise=new Promise(function(resolve,reject){var readRequest={_resolve:resolve,_reject:reject};stream._reader._readRequests.push(readRequest)});return promise}function ReadableStreamCancel(stream,reason){if(stream._disturbed=!0,\"closed\"===stream._state)return Promise.resolve(void 0);if(\"errored\"===stream._state)return Promise.reject(stream._storedError);ReadableStreamClose(stream);var sourceCancelPromise=stream._readableStreamController[InternalCancel](reason);return sourceCancelPromise.then(function(){})}function ReadableStreamClose(stream){assert(\"readable\"===stream._state),stream._state=\"closed\";var reader=stream._reader;if(void 0!==reader){if(IsReadableStreamDefaultReader(reader)===!0){var _iteratorNormalCompletion=!0,_didIteratorError=!1,_iteratorError=void 0;try{for(var _step,_iterator=reader._readRequests[Symbol.iterator]();!(_iteratorNormalCompletion=(_step=_iterator.next()).done);_iteratorNormalCompletion=!0){var _resolve=_step.value._resolve;_resolve(CreateIterResultObject(void 0,!0))}}catch(err){_didIteratorError=!0,_iteratorError=err}finally{try{!_iteratorNormalCompletion&&_iterator.return&&_iterator.return()}finally{if(_didIteratorError)throw _iteratorError}}reader._readRequests=[]}reader._closedPromise_resolve(void 0),reader._closedPromise_resolve=void 0,reader._closedPromise_reject=void 0}}function ReadableStreamError(stream,e){assert(IsReadableStream(stream)===!0,\"stream must be ReadableStream\"),assert(\"readable\"===stream._state,\"state must be readable\"),stream._state=\"errored\",stream._storedError=e;var reader=stream._reader;if(void 0!==reader){if(IsReadableStreamDefaultReader(reader)===!0){var _iteratorNormalCompletion2=!0,_didIteratorError2=!1,_iteratorError2=void 0;try{for(var _step2,_iterator2=reader._readRequests[Symbol.iterator]();!(_iteratorNormalCompletion2=(_step2=_iterator2.next()).done);_iteratorNormalCompletion2=!0){var readRequest=_step2.value;readRequest._reject(e)}}catch(err){_didIteratorError2=!0,_iteratorError2=err}finally{try{!_iteratorNormalCompletion2&&_iterator2.return&&_iterator2.return()}finally{if(_didIteratorError2)throw _iteratorError2}}reader._readRequests=[]}else{assert(IsReadableStreamBYOBReader(reader),\"reader must be ReadableStreamBYOBReader\");var _iteratorNormalCompletion3=!0,_didIteratorError3=!1,_iteratorError3=void 0;try{for(var _step3,_iterator3=reader._readIntoRequests[Symbol.iterator]();!(_iteratorNormalCompletion3=(_step3=_iterator3.next()).done);_iteratorNormalCompletion3=!0){var readIntoRequest=_step3.value;readIntoRequest._reject(e)}}catch(err){_didIteratorError3=!0,_iteratorError3=err}finally{try{!_iteratorNormalCompletion3&&_iterator3.return&&_iterator3.return()}finally{if(_didIteratorError3)throw _iteratorError3}}reader._readIntoRequests=[]}reader._closedPromise_reject(e),reader._closedPromise_resolve=void 0,reader._closedPromise_reject=void 0}}function ReadableStreamFulfillReadIntoRequest(stream,chunk,done){var reader=stream._reader;assert(reader._readIntoRequests.length>0);var readIntoRequest=reader._readIntoRequests.shift();readIntoRequest._resolve(CreateIterResultObject(chunk,done))}function ReadableStreamFulfillReadRequest(stream,chunk,done){var reader=stream._reader;assert(reader._readRequests.length>0);var readRequest=reader._readRequests.shift();readRequest._resolve(CreateIterResultObject(chunk,done))}function ReadableStreamGetNumReadIntoRequests(stream){return stream._reader._readIntoRequests.length}function ReadableStreamGetNumReadRequests(stream){return stream._reader._readRequests.length;\n}function ReadableStreamHasBYOBReader(stream){var reader=stream._reader;return void 0!==reader&&IsReadableStreamBYOBReader(reader)!==!1}function ReadableStreamHasDefaultReader(stream){var reader=stream._reader;return void 0!==reader&&IsReadableStreamDefaultReader(reader)!==!1}function IsReadableStreamBYOBReader(x){return!!typeIsObject(x)&&!!Object.prototype.hasOwnProperty.call(x,\"_readIntoRequests\")}function IsReadableStreamDefaultReader(x){return!!typeIsObject(x)&&!!Object.prototype.hasOwnProperty.call(x,\"_readRequests\")}function ReadableStreamReaderGenericInitialize(reader,stream){reader._ownerReadableStream=stream,stream._reader=reader,\"readable\"===stream._state?reader._closedPromise=new Promise(function(resolve,reject){reader._closedPromise_resolve=resolve,reader._closedPromise_reject=reject}):\"closed\"===stream._state?(reader._closedPromise=Promise.resolve(void 0),reader._closedPromise_resolve=void 0,reader._closedPromise_reject=void 0):(assert(\"errored\"===stream._state,\"state must be errored\"),reader._closedPromise=Promise.reject(stream._storedError),reader._closedPromise_resolve=void 0,reader._closedPromise_reject=void 0)}function ReadableStreamReaderGenericCancel(reader,reason){var stream=reader._ownerReadableStream;return assert(void 0!==stream),ReadableStreamCancel(stream,reason)}function ReadableStreamReaderGenericRelease(reader){assert(void 0!==reader._ownerReadableStream),assert(reader._ownerReadableStream._reader===reader),\"readable\"===reader._ownerReadableStream._state?reader._closedPromise_reject(new TypeError(\"Reader was released and can no longer be used to monitor the stream's closedness\")):reader._closedPromise=Promise.reject(new TypeError(\"Reader was released and can no longer be used to monitor the stream's closedness\")),reader._ownerReadableStream._reader=void 0,reader._ownerReadableStream=void 0}function ReadableStreamBYOBReaderRead(reader,view){var stream=reader._ownerReadableStream;return assert(void 0!==stream),stream._disturbed=!0,\"errored\"===stream._state?Promise.reject(stream._storedError):ReadableByteStreamControllerPullInto(stream._readableStreamController,view)}function ReadableStreamDefaultReaderRead(reader){var stream=reader._ownerReadableStream;return assert(void 0!==stream),stream._disturbed=!0,\"closed\"===stream._state?Promise.resolve(CreateIterResultObject(void 0,!0)):\"errored\"===stream._state?Promise.reject(stream._storedError):(assert(\"readable\"===stream._state),stream._readableStreamController[InternalPull]())}function IsReadableStreamDefaultController(x){return!!typeIsObject(x)&&!!Object.prototype.hasOwnProperty.call(x,\"_underlyingSource\")}function ReadableStreamDefaultControllerCallPullIfNeeded(controller){var shouldPull=ReadableStreamDefaultControllerShouldCallPull(controller);if(shouldPull!==!1){if(controller._pulling===!0)return void(controller._pullAgain=!0);controller._pulling=!0;var pullPromise=PromiseInvokeOrNoop(controller._underlyingSource,\"pull\",[controller]);pullPromise.then(function(){if(controller._pulling=!1,controller._pullAgain===!0)return controller._pullAgain=!1,ReadableStreamDefaultControllerCallPullIfNeeded(controller)},function(e){if(\"readable\"===controller._controlledReadableStream._state)return ReadableStreamDefaultControllerError(controller,e)}).catch(rethrowAssertionErrorRejection)}}function ReadableStreamDefaultControllerShouldCallPull(controller){var stream=controller._controlledReadableStream;if(\"closed\"===stream._state||\"errored\"===stream._state)return!1;if(controller._closeRequested===!0)return!1;if(controller._started===!1)return!1;if(IsReadableStreamLocked(stream)===!0&&ReadableStreamGetNumReadRequests(stream)>0)return!0;var desiredSize=ReadableStreamDefaultControllerGetDesiredSize(controller);return desiredSize>0}function ReadableStreamDefaultControllerClose(controller){var stream=controller._controlledReadableStream;assert(controller._closeRequested===!1),assert(\"readable\"===stream._state),controller._closeRequested=!0,0===controller._queue.length&&ReadableStreamClose(stream)}function ReadableStreamDefaultControllerEnqueue(controller,chunk){var stream=controller._controlledReadableStream;if(assert(controller._closeRequested===!1),assert(\"readable\"===stream._state),IsReadableStreamLocked(stream)===!0&&ReadableStreamGetNumReadRequests(stream)>0)ReadableStreamFulfillReadRequest(stream,chunk,!1);else{var chunkSize=1;if(void 0!==controller._strategySize)try{chunkSize=controller._strategySize(chunk)}catch(chunkSizeE){throw\"readable\"===stream._state&&ReadableStreamDefaultControllerError(controller,chunkSizeE),chunkSizeE}try{EnqueueValueWithSize(controller._queue,chunk,chunkSize)}catch(enqueueE){throw\"readable\"===stream._state&&ReadableStreamDefaultControllerError(controller,enqueueE),enqueueE}}ReadableStreamDefaultControllerCallPullIfNeeded(controller)}function ReadableStreamDefaultControllerError(controller,e){var stream=controller._controlledReadableStream;assert(\"readable\"===stream._state),controller._queue=[],ReadableStreamError(stream,e)}function ReadableStreamDefaultControllerGetDesiredSize(controller){var queueSize=GetTotalQueueSize(controller._queue);return controller._strategyHWM-queueSize}function IsReadableByteStreamController(x){return!!typeIsObject(x)&&!!Object.prototype.hasOwnProperty.call(x,\"_underlyingByteSource\")}function IsReadableStreamBYOBRequest(x){return!!typeIsObject(x)&&!!Object.prototype.hasOwnProperty.call(x,\"_associatedReadableByteStreamController\")}function ReadableByteStreamControllerCallPullIfNeeded(controller){var shouldPull=ReadableByteStreamControllerShouldCallPull(controller);if(shouldPull!==!1){if(controller._pulling===!0)return void(controller._pullAgain=!0);controller._pullAgain=!1,controller._pulling=!0;var pullPromise=PromiseInvokeOrNoop(controller._underlyingByteSource,\"pull\",[controller]);pullPromise.then(function(){controller._pulling=!1,controller._pullAgain===!0&&(controller._pullAgain=!1,ReadableByteStreamControllerCallPullIfNeeded(controller))},function(e){\"readable\"===controller._controlledReadableStream._state&&ReadableByteStreamControllerError(controller,e)}).catch(rethrowAssertionErrorRejection)}}function ReadableByteStreamControllerClearPendingPullIntos(controller){ReadableByteStreamControllerInvalidateBYOBRequest(controller),controller._pendingPullIntos=[]}function ReadableByteStreamControllerCommitPullIntoDescriptor(stream,pullIntoDescriptor){assert(\"errored\"!==stream._state,\"state must not be errored\");var done=!1;\"closed\"===stream._state&&(assert(0===pullIntoDescriptor.bytesFilled),done=!0);var filledView=ReadableByteStreamControllerConvertPullIntoDescriptor(pullIntoDescriptor);\"default\"===pullIntoDescriptor.readerType?ReadableStreamFulfillReadRequest(stream,filledView,done):(assert(\"byob\"===pullIntoDescriptor.readerType),ReadableStreamFulfillReadIntoRequest(stream,filledView,done))}function ReadableByteStreamControllerConvertPullIntoDescriptor(pullIntoDescriptor){var bytesFilled=pullIntoDescriptor.bytesFilled,elementSize=pullIntoDescriptor.elementSize;return assert(bytesFilled<=pullIntoDescriptor.byteLength),assert(bytesFilled%elementSize===0),new pullIntoDescriptor.ctor(pullIntoDescriptor.buffer,pullIntoDescriptor.byteOffset,bytesFilled/elementSize)}function ReadableByteStreamControllerEnqueueChunkToQueue(controller,buffer,byteOffset,byteLength){controller._queue.push({buffer:buffer,byteOffset:byteOffset,byteLength:byteLength}),controller._totalQueuedBytes+=byteLength}function ReadableByteStreamControllerFillPullIntoDescriptorFromQueue(controller,pullIntoDescriptor){var elementSize=pullIntoDescriptor.elementSize,currentAlignedBytes=pullIntoDescriptor.bytesFilled-pullIntoDescriptor.bytesFilled%elementSize,maxBytesToCopy=Math.min(controller._totalQueuedBytes,pullIntoDescriptor.byteLength-pullIntoDescriptor.bytesFilled),maxBytesFilled=pullIntoDescriptor.bytesFilled+maxBytesToCopy,maxAlignedBytes=maxBytesFilled-maxBytesFilled%elementSize,totalBytesToCopyRemaining=maxBytesToCopy,ready=!1;maxAlignedBytes>currentAlignedBytes&&(totalBytesToCopyRemaining=maxAlignedBytes-pullIntoDescriptor.bytesFilled,ready=!0);for(var queue=controller._queue;totalBytesToCopyRemaining>0;){var headOfQueue=queue[0],bytesToCopy=Math.min(totalBytesToCopyRemaining,headOfQueue.byteLength),destStart=pullIntoDescriptor.byteOffset+pullIntoDescriptor.bytesFilled;ArrayBufferCopy(pullIntoDescriptor.buffer,destStart,headOfQueue.buffer,headOfQueue.byteOffset,bytesToCopy),headOfQueue.byteLength===bytesToCopy?queue.shift():(headOfQueue.byteOffset+=bytesToCopy,headOfQueue.byteLength-=bytesToCopy),controller._totalQueuedBytes-=bytesToCopy,ReadableByteStreamControllerFillHeadPullIntoDescriptor(controller,bytesToCopy,pullIntoDescriptor),totalBytesToCopyRemaining-=bytesToCopy}return ready===!1&&(assert(0===controller._totalQueuedBytes,\"queue must be empty\"),assert(pullIntoDescriptor.bytesFilled>0),assert(pullIntoDescriptor.bytesFilled0;){if(0===controller._totalQueuedBytes)return;var pullIntoDescriptor=controller._pendingPullIntos[0];ReadableByteStreamControllerFillPullIntoDescriptorFromQueue(controller,pullIntoDescriptor)===!0&&(ReadableByteStreamControllerShiftPendingPullInto(controller),ReadableByteStreamControllerCommitPullIntoDescriptor(controller._controlledReadableStream,pullIntoDescriptor))}}function ReadableByteStreamControllerPullInto(controller,view){var stream=controller._controlledReadableStream,elementSize=1;view.constructor!==DataView&&(elementSize=view.constructor.BYTES_PER_ELEMENT);var ctor=view.constructor,pullIntoDescriptor={buffer:view.buffer,byteOffset:view.byteOffset,byteLength:view.byteLength,bytesFilled:0,elementSize:elementSize,ctor:ctor,readerType:\"byob\"};if(controller._pendingPullIntos.length>0)return pullIntoDescriptor.buffer=SameRealmTransfer(pullIntoDescriptor.buffer),controller._pendingPullIntos.push(pullIntoDescriptor),ReadableStreamAddReadIntoRequest(stream);if(\"closed\"===stream._state){var emptyView=new view.constructor(view.buffer,view.byteOffset,0);return Promise.resolve(CreateIterResultObject(emptyView,!0))}if(controller._totalQueuedBytes>0){if(ReadableByteStreamControllerFillPullIntoDescriptorFromQueue(controller,pullIntoDescriptor)===!0){var filledView=ReadableByteStreamControllerConvertPullIntoDescriptor(pullIntoDescriptor);return ReadableByteStreamControllerHandleQueueDrain(controller),Promise.resolve(CreateIterResultObject(filledView,!1))}if(controller._closeRequested===!0){var e=new TypeError(\"Insufficient bytes to fill elements in the given buffer\");return ReadableByteStreamControllerError(controller,e),Promise.reject(e)}}pullIntoDescriptor.buffer=SameRealmTransfer(pullIntoDescriptor.buffer),controller._pendingPullIntos.push(pullIntoDescriptor);var promise=ReadableStreamAddReadIntoRequest(stream);return ReadableByteStreamControllerCallPullIfNeeded(controller),promise}function ReadableByteStreamControllerRespondInClosedState(controller,firstDescriptor){firstDescriptor.buffer=SameRealmTransfer(firstDescriptor.buffer),assert(0===firstDescriptor.bytesFilled,\"bytesFilled must be 0\");for(var stream=controller._controlledReadableStream;ReadableStreamGetNumReadIntoRequests(stream)>0;){var pullIntoDescriptor=ReadableByteStreamControllerShiftPendingPullInto(controller);ReadableByteStreamControllerCommitPullIntoDescriptor(stream,pullIntoDescriptor)}}function ReadableByteStreamControllerRespondInReadableState(controller,bytesWritten,pullIntoDescriptor){if(pullIntoDescriptor.bytesFilled+bytesWritten>pullIntoDescriptor.byteLength)throw new RangeError(\"bytesWritten out of range\");if(ReadableByteStreamControllerFillHeadPullIntoDescriptor(controller,bytesWritten,pullIntoDescriptor),!(pullIntoDescriptor.bytesFilled0){var end=pullIntoDescriptor.byteOffset+pullIntoDescriptor.bytesFilled,remainder=pullIntoDescriptor.buffer.slice(end-remainderSize,end);ReadableByteStreamControllerEnqueueChunkToQueue(controller,remainder,0,remainder.byteLength)}pullIntoDescriptor.buffer=SameRealmTransfer(pullIntoDescriptor.buffer),pullIntoDescriptor.bytesFilled-=remainderSize,ReadableByteStreamControllerCommitPullIntoDescriptor(controller._controlledReadableStream,pullIntoDescriptor),ReadableByteStreamControllerProcessPullIntoDescriptorsUsingQueue(controller)}}function ReadableByteStreamControllerRespondInternal(controller,bytesWritten){var firstDescriptor=controller._pendingPullIntos[0],stream=controller._controlledReadableStream;if(\"closed\"===stream._state){if(0!==bytesWritten)throw new TypeError(\"bytesWritten must be 0 when calling respond() on a closed stream\");ReadableByteStreamControllerRespondInClosedState(controller,firstDescriptor)}else assert(\"readable\"===stream._state),ReadableByteStreamControllerRespondInReadableState(controller,bytesWritten,firstDescriptor)}function ReadableByteStreamControllerShiftPendingPullInto(controller){var descriptor=controller._pendingPullIntos.shift();return ReadableByteStreamControllerInvalidateBYOBRequest(controller),descriptor}function ReadableByteStreamControllerShouldCallPull(controller){var stream=controller._controlledReadableStream;return\"readable\"===stream._state&&(controller._closeRequested!==!0&&(controller._started!==!1&&(!!(ReadableStreamHasDefaultReader(stream)&&ReadableStreamGetNumReadRequests(stream)>0)||(!!(ReadableStreamHasBYOBReader(stream)&&ReadableStreamGetNumReadIntoRequests(stream)>0)||ReadableByteStreamControllerGetDesiredSize(controller)>0))))}function ReadableByteStreamControllerClose(controller){var stream=controller._controlledReadableStream;if(assert(controller._closeRequested===!1),assert(\"readable\"===stream._state),controller._totalQueuedBytes>0)return void(controller._closeRequested=!0);if(controller._pendingPullIntos.length>0){var firstPendingPullInto=controller._pendingPullIntos[0];if(firstPendingPullInto.bytesFilled>0){var e=new TypeError(\"Insufficient bytes to fill elements in the given buffer\");throw ReadableByteStreamControllerError(controller,e),e}}ReadableStreamClose(stream)}function ReadableByteStreamControllerEnqueue(controller,chunk){var stream=controller._controlledReadableStream;assert(controller._closeRequested===!1),assert(\"readable\"===stream._state);var buffer=chunk.buffer,byteOffset=chunk.byteOffset,byteLength=chunk.byteLength,transferredBuffer=SameRealmTransfer(buffer);if(ReadableStreamHasDefaultReader(stream)===!0)if(0===ReadableStreamGetNumReadRequests(stream))ReadableByteStreamControllerEnqueueChunkToQueue(controller,transferredBuffer,byteOffset,byteLength);else{assert(0===controller._queue.length);var transferredView=new Uint8Array(transferredBuffer,byteOffset,byteLength);ReadableStreamFulfillReadRequest(stream,transferredView,!1)}else ReadableStreamHasBYOBReader(stream)===!0?(ReadableByteStreamControllerEnqueueChunkToQueue(controller,transferredBuffer,byteOffset,byteLength),ReadableByteStreamControllerProcessPullIntoDescriptorsUsingQueue(controller)):(assert(IsReadableStreamLocked(stream)===!1,\"stream must not be locked\"),ReadableByteStreamControllerEnqueueChunkToQueue(controller,transferredBuffer,byteOffset,byteLength))}function ReadableByteStreamControllerError(controller,e){var stream=controller._controlledReadableStream;assert(\"readable\"===stream._state),ReadableByteStreamControllerClearPendingPullIntos(controller),controller._queue=[],ReadableStreamError(stream,e)}function ReadableByteStreamControllerGetDesiredSize(controller){return controller._strategyHWM-controller._totalQueuedBytes}function ReadableByteStreamControllerRespond(controller,bytesWritten){if(bytesWritten=Number(bytesWritten),IsFiniteNonNegativeNumber(bytesWritten)===!1)throw new RangeError(\"bytesWritten must be a finite\");assert(controller._pendingPullIntos.length>0),ReadableByteStreamControllerRespondInternal(controller,bytesWritten)}function ReadableByteStreamControllerRespondWithNewView(controller,view){assert(controller._pendingPullIntos.length>0);var firstDescriptor=controller._pendingPullIntos[0];if(firstDescriptor.byteOffset+firstDescriptor.bytesFilled!==view.byteOffset)throw new RangeError(\"The region specified by view does not match byobRequest\");if(firstDescriptor.byteLength!==view.byteLength)throw new RangeError(\"The buffer of view has different capacity than byobRequest\");firstDescriptor.buffer=view.buffer,ReadableByteStreamControllerRespondInternal(controller,view.byteLength)}var _slicedToArray=function(){function sliceIterator(arr,i){var _arr=[],_n=!0,_d=!1,_e=void 0;try{for(var _s,_i=arr[Symbol.iterator]();!(_n=(_s=_i.next()).done)&&(_arr.push(_s.value),!i||_arr.length!==i);_n=!0);}catch(err){_d=!0,_e=err}finally{try{!_n&&_i.return&&_i.return()}finally{if(_d)throw _e}}return _arr}return function(arr,i){if(Array.isArray(arr))return arr;if(Symbol.iterator in Object(arr))return sliceIterator(arr,i);throw new TypeError(\"Invalid attempt to destructure non-iterable instance\")}}(),_createClass=function(){function defineProperties(target,props){for(var i=0;i0)throw new TypeError(\"Tried to release a reader lock when that reader has pending read() calls un-settled\");ReadableStreamReaderGenericRelease(this)}}},{key:\"closed\",get:function(){return IsReadableStreamDefaultReader(this)===!1?Promise.reject(new TypeError(\"ReadableStreamDefaultReader.prototype.closed can only be used on a ReadableStreamDefaultReader\")):this._closedPromise}}]),ReadableStreamDefaultReader}(),ReadableStreamBYOBReader=function(){function ReadableStreamBYOBReader(stream){if(_classCallCheck(this,ReadableStreamBYOBReader),!IsReadableStream(stream))throw new TypeError(\"ReadableStreamBYOBReader can only be constructed with a ReadableStream instance given a byte source\");if(IsReadableStreamLocked(stream))throw new TypeError(\"This stream has already been locked for exclusive reading by another reader\");ReadableStreamReaderGenericInitialize(this,stream),this._readIntoRequests=[]}return _createClass(ReadableStreamBYOBReader,[{key:\"cancel\",value:function(reason){return IsReadableStreamBYOBReader(this)?void 0===this._ownerReadableStream?Promise.reject(new TypeError(\"Cannot cancel a stream using a released reader\")):ReadableStreamReaderGenericCancel(this,reason):Promise.reject(new TypeError(\"ReadableStreamBYOBReader.prototype.cancel can only be used on a ReadableStreamBYOBReader\"))}},{key:\"read\",value:function(view){return IsReadableStreamBYOBReader(this)?void 0===this._ownerReadableStream?Promise.reject(new TypeError(\"Cannot read from a released reader\")):ArrayBuffer.isView(view)?0===view.byteLength?Promise.reject(new TypeError(\"view must have non-zero byteLength\")):ReadableStreamBYOBReaderRead(this,view):Promise.reject(new TypeError(\"view must be an array buffer view\")):Promise.reject(new TypeError(\"ReadableStreamBYOBReader.prototype.read can only be used on a ReadableStreamBYOBReader\"))}},{key:\"releaseLock\",value:function(){if(!IsReadableStreamBYOBReader(this))throw new TypeError(\"ReadableStreamBYOBReader.prototype.releaseLock can only be used on a ReadableStreamBYOBReader\");if(void 0!==this._ownerReadableStream){if(this._readIntoRequests.length>0)throw new TypeError(\"Tried to release a reader lock when that reader has pending read() calls un-settled\");ReadableStreamReaderGenericRelease(this)}}},{key:\"closed\",get:function(){return IsReadableStreamBYOBReader(this)?this._closedPromise:Promise.reject(new TypeError(\"ReadableStreamBYOBReader.prototype.closed can only be used on a ReadableStreamBYOBReader\"))}}]),ReadableStreamBYOBReader}(),ReadableStreamDefaultController=function(){function ReadableStreamDefaultController(stream,underlyingSource,size,highWaterMark){if(_classCallCheck(this,ReadableStreamDefaultController),IsReadableStream(stream)===!1)throw new TypeError(\"ReadableStreamDefaultController can only be constructed with a ReadableStream instance\");if(void 0!==stream._readableStreamController)throw new TypeError(\"ReadableStreamDefaultController instances can only be created by the ReadableStream constructor\");this._controlledReadableStream=stream,this._underlyingSource=underlyingSource,this._queue=[],this._started=!1,this._closeRequested=!1,this._pullAgain=!1,this._pulling=!1;var normalizedStrategy=ValidateAndNormalizeQueuingStrategy(size,highWaterMark);this._strategySize=normalizedStrategy.size,this._strategyHWM=normalizedStrategy.highWaterMark;var controller=this,startResult=InvokeOrNoop(underlyingSource,\"start\",[this]);Promise.resolve(startResult).then(function(){controller._started=!0,ReadableStreamDefaultControllerCallPullIfNeeded(controller)},function(r){\"readable\"===stream._state&&ReadableStreamDefaultControllerError(controller,r)}).catch(rethrowAssertionErrorRejection)}return _createClass(ReadableStreamDefaultController,[{key:\"close\",value:function(){if(IsReadableStreamDefaultController(this)===!1)throw new TypeError(\"ReadableStreamDefaultController.prototype.close can only be used on a ReadableStreamDefaultController\");if(this._closeRequested===!0)throw new TypeError(\"The stream has already been closed; do not close it again!\");var state=this._controlledReadableStream._state;if(\"readable\"!==state)throw new TypeError(\"The stream (in \"+state+\" state) is not in the readable state and cannot be closed\");ReadableStreamDefaultControllerClose(this)}},{key:\"enqueue\",value:function(chunk){if(IsReadableStreamDefaultController(this)===!1)throw new TypeError(\"ReadableStreamDefaultController.prototype.enqueue can only be used on a ReadableStreamDefaultController\");if(this._closeRequested===!0)throw new TypeError(\"stream is closed or draining\");var state=this._controlledReadableStream._state;if(\"readable\"!==state)throw new TypeError(\"The stream (in \"+state+\" state) is not in the readable state and cannot be enqueued to\");return ReadableStreamDefaultControllerEnqueue(this,chunk)}},{key:\"error\",value:function(e){if(IsReadableStreamDefaultController(this)===!1)throw new TypeError(\"ReadableStreamDefaultController.prototype.error can only be used on a ReadableStreamDefaultController\");var stream=this._controlledReadableStream;if(\"readable\"!==stream._state)throw new TypeError(\"The stream is \"+stream._state+\" and so cannot be errored\");ReadableStreamDefaultControllerError(this,e)}},{key:InternalCancel,value:function(reason){return this._queue=[],PromiseInvokeOrNoop(this._underlyingSource,\"cancel\",[reason])}},{key:InternalPull,value:function(){var stream=this._controlledReadableStream;if(this._queue.length>0){var chunk=DequeueValue(this._queue);return this._closeRequested===!0&&0===this._queue.length?ReadableStreamClose(stream):ReadableStreamDefaultControllerCallPullIfNeeded(this),Promise.resolve(CreateIterResultObject(chunk,!1))}var pendingPromise=ReadableStreamAddReadRequest(stream);return ReadableStreamDefaultControllerCallPullIfNeeded(this),pendingPromise}},{key:\"desiredSize\",get:function(){if(IsReadableStreamDefaultController(this)===!1)throw new TypeError(\"ReadableStreamDefaultController.prototype.desiredSize can only be used on a ReadableStreamDefaultController\");return ReadableStreamDefaultControllerGetDesiredSize(this)}}]),ReadableStreamDefaultController}(),ReadableStreamBYOBRequest=function(){function ReadableStreamBYOBRequest(controller,view){_classCallCheck(this,ReadableStreamBYOBRequest),this._associatedReadableByteStreamController=controller,this._view=view}return _createClass(ReadableStreamBYOBRequest,[{key:\"respond\",value:function(bytesWritten){if(IsReadableStreamBYOBRequest(this)===!1)throw new TypeError(\"ReadableByteStreamController.prototype.respond can only be used on a ReadableByteStreamController\");if(void 0===this._associatedReadableByteStreamController)throw new TypeError(\"This BYOB request has been invalidated\");ReadableByteStreamControllerRespond(this._associatedReadableByteStreamController,bytesWritten);\n}},{key:\"respondWithNewView\",value:function(view){if(IsReadableStreamBYOBRequest(this)===!1)throw new TypeError(\"ReadableByteStreamController.prototype.respond can only be used on a ReadableByteStreamController\");if(void 0===this._associatedReadableByteStreamController)throw new TypeError(\"This BYOB request has been invalidated\");if(!ArrayBuffer.isView(view))throw new TypeError(\"You can only respond with array buffer views\");ReadableByteStreamControllerRespondWithNewView(this._associatedReadableByteStreamController,view)}},{key:\"view\",get:function(){return this._view}}]),ReadableStreamBYOBRequest}(),ReadableByteStreamController=function(){function ReadableByteStreamController(stream,underlyingByteSource,highWaterMark){if(_classCallCheck(this,ReadableByteStreamController),IsReadableStream(stream)===!1)throw new TypeError(\"ReadableByteStreamController can only be constructed with a ReadableStream instance given a byte source\");if(void 0!==stream._readableStreamController)throw new TypeError(\"ReadableByteStreamController instances can only be created by the ReadableStream constructor given a byte source\");this._controlledReadableStream=stream,this._underlyingByteSource=underlyingByteSource,this._pullAgain=!1,this._pulling=!1,ReadableByteStreamControllerClearPendingPullIntos(this),this._queue=[],this._totalQueuedBytes=0,this._closeRequested=!1,this._started=!1,this._strategyHWM=ValidateAndNormalizeHighWaterMark(highWaterMark);var autoAllocateChunkSize=underlyingByteSource.autoAllocateChunkSize;if(void 0!==autoAllocateChunkSize&&(Number.isInteger(autoAllocateChunkSize)===!1||autoAllocateChunkSize<0))throw new RangeError(\"autoAllocateChunkSize must be a non negative integer\");this._autoAllocateChunkSize=autoAllocateChunkSize,this._pendingPullIntos=[];var controller=this,startResult=InvokeOrNoop(underlyingByteSource,\"start\",[this]);Promise.resolve(startResult).then(function(){controller._started=!0,assert(controller._pulling===!1),assert(controller._pullAgain===!1),ReadableByteStreamControllerCallPullIfNeeded(controller)},function(r){\"readable\"===stream._state&&ReadableByteStreamControllerError(controller,r)}).catch(rethrowAssertionErrorRejection)}return _createClass(ReadableByteStreamController,[{key:\"close\",value:function(){if(IsReadableByteStreamController(this)===!1)throw new TypeError(\"ReadableByteStreamController.prototype.close can only be used on a ReadableByteStreamController\");if(this._closeRequested===!0)throw new TypeError(\"The stream has already been closed; do not close it again!\");var state=this._controlledReadableStream._state;if(\"readable\"!==state)throw new TypeError(\"The stream (in \"+state+\" state) is not in the readable state and cannot be closed\");ReadableByteStreamControllerClose(this)}},{key:\"enqueue\",value:function(chunk){if(IsReadableByteStreamController(this)===!1)throw new TypeError(\"ReadableByteStreamController.prototype.enqueue can only be used on a ReadableByteStreamController\");if(this._closeRequested===!0)throw new TypeError(\"stream is closed or draining\");var state=this._controlledReadableStream._state;if(\"readable\"!==state)throw new TypeError(\"The stream (in \"+state+\" state) is not in the readable state and cannot be enqueued to\");if(!ArrayBuffer.isView(chunk))throw new TypeError(\"You can only enqueue array buffer views when using a ReadableByteStreamController\");ReadableByteStreamControllerEnqueue(this,chunk)}},{key:\"error\",value:function(e){if(IsReadableByteStreamController(this)===!1)throw new TypeError(\"ReadableByteStreamController.prototype.error can only be used on a ReadableByteStreamController\");var stream=this._controlledReadableStream;if(\"readable\"!==stream._state)throw new TypeError(\"The stream is \"+stream._state+\" and so cannot be errored\");ReadableByteStreamControllerError(this,e)}},{key:InternalCancel,value:function(reason){if(this._pendingPullIntos.length>0){var firstDescriptor=this._pendingPullIntos[0];firstDescriptor.bytesFilled=0}return this._queue=[],this._totalQueuedBytes=0,PromiseInvokeOrNoop(this._underlyingByteSource,\"cancel\",[reason])}},{key:InternalPull,value:function(){var stream=this._controlledReadableStream;if(0===ReadableStreamGetNumReadRequests(stream)){if(this._totalQueuedBytes>0){var entry=this._queue.shift();this._totalQueuedBytes-=entry.byteLength,ReadableByteStreamControllerHandleQueueDrain(this);var view=void 0;try{view=new Uint8Array(entry.buffer,entry.byteOffset,entry.byteLength)}catch(viewE){return Promise.reject(viewE)}return Promise.resolve(CreateIterResultObject(view,!1))}var autoAllocateChunkSize=this._autoAllocateChunkSize;if(void 0!==autoAllocateChunkSize){var buffer=void 0;try{buffer=new ArrayBuffer(autoAllocateChunkSize)}catch(bufferE){return Promise.reject(bufferE)}var pullIntoDescriptor={buffer:buffer,byteOffset:0,byteLength:autoAllocateChunkSize,bytesFilled:0,elementSize:1,ctor:Uint8Array,readerType:\"default\"};this._pendingPullIntos.push(pullIntoDescriptor)}}else assert(void 0===this._autoAllocateChunkSize);var promise=ReadableStreamAddReadRequest(stream);return ReadableByteStreamControllerCallPullIfNeeded(this),promise}},{key:\"byobRequest\",get:function(){if(IsReadableByteStreamController(this)===!1)throw new TypeError(\"ReadableByteStreamController.prototype.byobRequest can only be used on a ReadableByteStreamController\");if(void 0===this._byobRequest&&this._pendingPullIntos.length>0){var firstDescriptor=this._pendingPullIntos[0],view=new Uint8Array(firstDescriptor.buffer,firstDescriptor.byteOffset+firstDescriptor.bytesFilled,firstDescriptor.byteLength-firstDescriptor.bytesFilled);this._byobRequest=new ReadableStreamBYOBRequest(this,view)}return this._byobRequest}},{key:\"desiredSize\",get:function(){if(IsReadableByteStreamController(this)===!1)throw new TypeError(\"ReadableByteStreamController.prototype.desiredSize can only be used on a ReadableByteStreamController\");return ReadableByteStreamControllerGetDesiredSize(this)}}]),ReadableByteStreamController}()},{\"./helpers.js\":9,\"./queue-with-sizes.js\":10,\"./utils.js\":13,assert:2}],12:[function(require,module,exports){\"use strict\";function _classCallCheck(instance,Constructor){if(!(instance instanceof Constructor))throw new TypeError(\"Cannot call a class as a function\")}var _require=require(\"./readable-stream.js\"),ReadableStream=_require.ReadableStream,_require2=require(\"./writable-stream.js\"),WritableStream=_require2.WritableStream;module.exports=function TransformStream(transformer){function maybeDoTransform(){if(transforming===!1){transforming=!0;try{transformer.transform(writeChunk,enqueueInReadable,transformDone),writeChunk=void 0,chunkWrittenButNotYetTransformed=!1}catch(e){transforming=!1,errorWritable(e),errorReadable(e)}}}function transformDone(){transforming=!1,writeDone()}if(_classCallCheck(this,TransformStream),void 0===transformer.flush&&(transformer.flush=function(enqueue,close){return close()}),\"function\"!=typeof transformer.transform)throw new TypeError(\"transform must be a function\");var writeChunk=void 0,writeDone=void 0,errorWritable=void 0,transforming=!1,chunkWrittenButNotYetTransformed=!1;this.writable=new WritableStream({start:function(error){errorWritable=error},write:function(chunk){writeChunk=chunk,chunkWrittenButNotYetTransformed=!0;var p=new Promise(function(resolve){return writeDone=resolve});return maybeDoTransform(),p},close:function(){try{transformer.flush(enqueueInReadable,closeReadable)}catch(e){errorWritable(e),errorReadable(e)}}},transformer.writableStrategy);var enqueueInReadable=void 0,closeReadable=void 0,errorReadable=void 0;this.readable=new ReadableStream({start:function(c){enqueueInReadable=c.enqueue.bind(c),closeReadable=c.close.bind(c),errorReadable=c.error.bind(c)},pull:function(){chunkWrittenButNotYetTransformed===!0&&maybeDoTransform()}},transformer.readableStrategy)}},{\"./readable-stream.js\":11,\"./writable-stream.js\":14}],13:[function(require,module,exports){\"use strict\";var assert=require(\"assert\");exports.rethrowAssertionErrorRejection=function(e){e&&e.constructor===assert.AssertionError&&setTimeout(function(){throw e},0)}},{assert:2}],14:[function(require,module,exports){\"use strict\";function _classCallCheck(instance,Constructor){if(!(instance instanceof Constructor))throw new TypeError(\"Cannot call a class as a function\")}function closure_WritableStreamErrorFunction(){var f=function f(e){return ErrorWritableStream(f._stream,e)};return f}function CallOrScheduleWritableStreamAdvanceQueue(stream){return stream._started===!1?void stream._startedPromise.then(function(){WritableStreamAdvanceQueue(stream)}).catch(rethrowAssertionErrorRejection):stream._started===!0?WritableStreamAdvanceQueue(stream):void 0}function CloseWritableStream(stream){assert(\"closing\"===stream._state,\"stream must be in closing state while calling CloseWritableStream\");var sinkClosePromise=PromiseInvokeOrNoop(stream._underlyingSink,\"close\");sinkClosePromise.then(function(){\"errored\"!==stream._state&&(assert(\"closing\"===stream._state),stream._closedPromise_resolve(void 0),stream._closedPromise_resolve=void 0,stream._closedPromise_reject=void 0,stream._state=\"closed\")},function(r){return ErrorWritableStream(stream,r)}).catch(rethrowAssertionErrorRejection)}function ErrorWritableStream(stream,e){if(\"closed\"!==stream._state&&\"errored\"!==stream._state){for(;stream._queue.length>0;){var writeRecord=DequeueValue(stream._queue);\"close\"!==writeRecord&&writeRecord._reject(e)}stream._storedError=e,\"waiting\"===stream._state&&stream._readyPromise_resolve(void 0),stream._closedPromise_reject(e),stream._closedPromise_resolve=void 0,stream._closedPromise_reject=void 0,stream._state=\"errored\"}}function IsWritableStream(x){return!!typeIsObject(x)&&!!Object.prototype.hasOwnProperty.call(x,\"_underlyingSink\")}function SyncWritableStreamStateWithQueue(stream){if(\"closing\"!==stream._state){assert(\"writable\"===stream._state||\"waiting\"===stream._state,\"stream must be in a writable or waiting state while calling SyncWritableStreamStateWithQueue\");var queueSize=GetTotalQueueSize(stream._queue),shouldApplyBackpressure=queueSize>stream._strategyHWM;shouldApplyBackpressure===!0&&\"writable\"===stream._state&&(stream._state=\"waiting\",stream._readyPromise=new Promise(function(resolve,reject){stream._readyPromise_resolve=resolve})),shouldApplyBackpressure===!1&&\"waiting\"===stream._state&&(stream._state=\"writable\",stream._readyPromise_resolve(void 0))}}function WritableStreamAdvanceQueue(stream){if(0!==stream._queue.length&&stream._writing!==!0){var writeRecord=PeekQueueValue(stream._queue);return\"close\"===writeRecord?(assert(\"closing\"===stream._state,\"can't process final write record unless already closing\"),DequeueValue(stream._queue),assert(0===stream._queue.length,\"queue must be empty once the final write record is dequeued\"),CloseWritableStream(stream)):(stream._writing=!0,void PromiseInvokeOrNoop(stream._underlyingSink,\"write\",[writeRecord.chunk]).then(function(){\"errored\"!==stream._state&&(stream._writing=!1,writeRecord._resolve(void 0),DequeueValue(stream._queue),SyncWritableStreamStateWithQueue(stream),WritableStreamAdvanceQueue(stream))},function(r){return ErrorWritableStream(stream,r)}).catch(rethrowAssertionErrorRejection))}}var _createClass=function(){function defineProperties(target,props){for(var i=0;i=0;i--)if(ka[i]!=kb[i])return!1;for(i=ka.length-1;i>=0;i--)if(key=ka[i],!_deepEqual(a[key],b[key]))return!1;return!0}function expectedException(actual,expected){return!(!actual||!expected)&&(\"[object RegExp]\"==Object.prototype.toString.call(expected)?expected.test(actual):actual instanceof expected||expected.call({},actual)===!0)}function _throws(shouldThrow,block,expected,message){var actual;util.isString(expected)&&(message=expected,expected=null);try{block()}catch(e){actual=e}if(message=(expected&&expected.name?\" (\"+expected.name+\").\":\".\")+(message?\" \"+message:\".\"),shouldThrow&&!actual&&fail(actual,expected,\"Missing expected exception\"+message),!shouldThrow&&expectedException(actual,expected)&&fail(actual,expected,\"Got unwanted exception\"+message),shouldThrow&&actual&&expected&&!expectedException(actual,expected)||!shouldThrow&&actual)throw actual}var util=require(\"util/\"),pSlice=Array.prototype.slice,hasOwn=Object.prototype.hasOwnProperty,assert=module.exports=ok;assert.AssertionError=function(options){this.name=\"AssertionError\",this.actual=options.actual,this.expected=options.expected,this.operator=options.operator,options.message?(this.message=options.message,this.generatedMessage=!1):(this.message=getMessage(this),this.generatedMessage=!0);var stackStartFunction=options.stackStartFunction||fail;if(Error.captureStackTrace)Error.captureStackTrace(this,stackStartFunction);else{var err=new Error;if(err.stack){var out=err.stack,fn_name=stackStartFunction.name,idx=out.indexOf(\"\\n\"+fn_name);if(idx>=0){var next_line=out.indexOf(\"\\n\",idx+1);out=out.substring(next_line+1)}this.stack=out}}},util.inherits(assert.AssertionError,Error),assert.fail=fail,assert.ok=ok,assert.equal=function(actual,expected,message){actual!=expected&&fail(actual,expected,message,\"==\",assert.equal)},assert.notEqual=function(actual,expected,message){actual==expected&&fail(actual,expected,message,\"!=\",assert.notEqual)},assert.deepEqual=function(actual,expected,message){_deepEqual(actual,expected)||fail(actual,expected,message,\"deepEqual\",assert.deepEqual)},assert.notDeepEqual=function(actual,expected,message){_deepEqual(actual,expected)&&fail(actual,expected,message,\"notDeepEqual\",assert.notDeepEqual)},assert.strictEqual=function(actual,expected,message){actual!==expected&&fail(actual,expected,message,\"===\",assert.strictEqual)},assert.notStrictEqual=function(actual,expected,message){actual===expected&&fail(actual,expected,message,\"!==\",assert.notStrictEqual)},assert.throws=function(block,error,message){_throws.apply(this,[!0].concat(pSlice.call(arguments)))},assert.doesNotThrow=function(block,message){_throws.apply(this,[!1].concat(pSlice.call(arguments)))},assert.ifError=function(err){if(err)throw err};var objectKeys=Object.keys||function(obj){var keys=[];for(var key in obj)hasOwn.call(obj,key)&&keys.push(key);return keys}},{\"util/\":6}],3:[function(require,module,exports){\"function\"==typeof Object.create?module.exports=function(ctor,superCtor){ctor.super_=superCtor,ctor.prototype=Object.create(superCtor.prototype,{constructor:{value:ctor,enumerable:!1,writable:!0,configurable:!0}})}:module.exports=function(ctor,superCtor){ctor.super_=superCtor;var TempCtor=function(){};TempCtor.prototype=superCtor.prototype,ctor.prototype=new TempCtor,ctor.prototype.constructor=ctor}},{}],4:[function(require,module,exports){function cleanUpNextTick(){draining&¤tQueue&&(draining=!1,currentQueue.length?queue=currentQueue.concat(queue):queueIndex=-1,queue.length&&drainQueue())}function drainQueue(){if(!draining){var timeout=cachedSetTimeout(cleanUpNextTick);draining=!0;for(var len=queue.length;len;){for(currentQueue=queue,queue=[];++queueIndex1)for(var i=1;i=3&&(ctx.depth=arguments[2]),arguments.length>=4&&(ctx.colors=arguments[3]),isBoolean(opts)?ctx.showHidden=opts:opts&&exports._extend(ctx,opts),isUndefined(ctx.showHidden)&&(ctx.showHidden=!1),isUndefined(ctx.depth)&&(ctx.depth=2),isUndefined(ctx.colors)&&(ctx.colors=!1),isUndefined(ctx.customInspect)&&(ctx.customInspect=!0),ctx.colors&&(ctx.stylize=stylizeWithColor),formatValue(ctx,obj,ctx.depth)}function stylizeWithColor(str,styleType){var style=inspect.styles[styleType];return style?\"\u001b[\"+inspect.colors[style][0]+\"m\"+str+\"\u001b[\"+inspect.colors[style][1]+\"m\":str}function stylizeNoColor(str,styleType){return str}function arrayToHash(array){var hash={};return array.forEach(function(val,idx){hash[val]=!0}),hash}function formatValue(ctx,value,recurseTimes){if(ctx.customInspect&&value&&isFunction(value.inspect)&&value.inspect!==exports.inspect&&(!value.constructor||value.constructor.prototype!==value)){var ret=value.inspect(recurseTimes,ctx);return isString(ret)||(ret=formatValue(ctx,ret,recurseTimes)),ret}var primitive=formatPrimitive(ctx,value);if(primitive)return primitive;var keys=Object.keys(value),visibleKeys=arrayToHash(keys);if(ctx.showHidden&&(keys=Object.getOwnPropertyNames(value)),isError(value)&&(keys.indexOf(\"message\")>=0||keys.indexOf(\"description\")>=0))return formatError(value);if(0===keys.length){if(isFunction(value)){var name=value.name?\": \"+value.name:\"\";return ctx.stylize(\"[Function\"+name+\"]\",\"special\")}if(isRegExp(value))return ctx.stylize(RegExp.prototype.toString.call(value),\"regexp\");if(isDate(value))return ctx.stylize(Date.prototype.toString.call(value),\"date\");if(isError(value))return formatError(value)}var base=\"\",array=!1,braces=[\"{\",\"}\"];if(isArray(value)&&(array=!0,braces=[\"[\",\"]\"]),isFunction(value)){var n=value.name?\": \"+value.name:\"\";base=\" [Function\"+n+\"]\"}if(isRegExp(value)&&(base=\" \"+RegExp.prototype.toString.call(value)),isDate(value)&&(base=\" \"+Date.prototype.toUTCString.call(value)),isError(value)&&(base=\" \"+formatError(value)),0===keys.length&&(!array||0==value.length))return braces[0]+base+braces[1];if(recurseTimes<0)return isRegExp(value)?ctx.stylize(RegExp.prototype.toString.call(value),\"regexp\"):ctx.stylize(\"[Object]\",\"special\");ctx.seen.push(value);var output;return output=array?formatArray(ctx,value,recurseTimes,visibleKeys,keys):keys.map(function(key){return formatProperty(ctx,value,recurseTimes,visibleKeys,key,array)}),ctx.seen.pop(),reduceToSingleString(output,base,braces)}function formatPrimitive(ctx,value){if(isUndefined(value))return ctx.stylize(\"undefined\",\"undefined\");if(isString(value)){var simple=\"'\"+JSON.stringify(value).replace(/^\"|\"$/g,\"\").replace(/'/g,\"\\\\'\").replace(/\\\\\"/g,'\"')+\"'\";return ctx.stylize(simple,\"string\")}return isNumber(value)?ctx.stylize(\"\"+value,\"number\"):isBoolean(value)?ctx.stylize(\"\"+value,\"boolean\"):isNull(value)?ctx.stylize(\"null\",\"null\"):void 0}function formatError(value){return\"[\"+Error.prototype.toString.call(value)+\"]\"}function formatArray(ctx,value,recurseTimes,visibleKeys,keys){for(var output=[],i=0,l=value.length;i-1&&(str=array?str.split(\"\\n\").map(function(line){return\" \"+line}).join(\"\\n\").substr(2):\"\\n\"+str.split(\"\\n\").map(function(line){return\" \"+line}).join(\"\\n\"))):str=ctx.stylize(\"[Circular]\",\"special\")),isUndefined(name)){if(array&&key.match(/^\\d+$/))return str;name=JSON.stringify(\"\"+key),name.match(/^\"([a-zA-Z_][a-zA-Z_0-9]*)\"$/)?(name=name.substr(1,name.length-2),name=ctx.stylize(name,\"name\")):(name=name.replace(/'/g,\"\\\\'\").replace(/\\\\\"/g,'\"').replace(/(^\"|\"$)/g,\"'\"),name=ctx.stylize(name,\"string\"))}return name+\": \"+str}function reduceToSingleString(output,base,braces){var numLinesEst=0,length=output.reduce(function(prev,cur){return numLinesEst++,cur.indexOf(\"\\n\")>=0&&numLinesEst++,prev+cur.replace(/\\u001b\\[\\d\\d?m/g,\"\").length+1},0);return length>60?braces[0]+(\"\"===base?\"\":base+\"\\n \")+\" \"+output.join(\",\\n \")+\" \"+braces[1]:braces[0]+base+\" \"+output.join(\", \")+\" \"+braces[1]}function isArray(ar){return Array.isArray(ar)}function isBoolean(arg){return\"boolean\"==typeof arg}function isNull(arg){return null===arg}function isNullOrUndefined(arg){return null==arg}function isNumber(arg){return\"number\"==typeof arg}function isString(arg){return\"string\"==typeof arg}function isSymbol(arg){return\"symbol\"==typeof arg}function isUndefined(arg){return void 0===arg}function isRegExp(re){return isObject(re)&&\"[object RegExp]\"===objectToString(re)}function isObject(arg){return\"object\"==typeof arg&&null!==arg}function isDate(d){return isObject(d)&&\"[object Date]\"===objectToString(d)}function isError(e){return isObject(e)&&(\"[object Error]\"===objectToString(e)||e instanceof Error)}function isFunction(arg){return\"function\"==typeof arg}function isPrimitive(arg){return null===arg||\"boolean\"==typeof arg||\"number\"==typeof arg||\"string\"==typeof arg||\"symbol\"==typeof arg||\"undefined\"==typeof arg}function objectToString(o){return Object.prototype.toString.call(o)}function pad(n){return n<10?\"0\"+n.toString(10):n.toString(10)}function timestamp(){var d=new Date,time=[pad(d.getHours()),pad(d.getMinutes()),pad(d.getSeconds())].join(\":\");return[d.getDate(),months[d.getMonth()],time].join(\" \")}function hasOwnProperty(obj,prop){return Object.prototype.hasOwnProperty.call(obj,prop)}var formatRegExp=/%[sdj%]/g;exports.format=function(f){if(!isString(f)){for(var objects=[],i=0;i=len)return x;switch(x){case\"%s\":return String(args[i++]);case\"%d\":return Number(args[i++]);case\"%j\":try{return JSON.stringify(args[i++])}catch(_){return\"[Circular]\"}default:return x}}),x=args[i];i1?_len-1:0),_key=1;_key<_len;_key++)args[_key-1]=arguments[_key];try{return Promise.resolve(func.apply(void 0,args))}catch(e){return Promise.reject(e)}},exports.typeIsObject=function(x){return\"object\"===(\"undefined\"==typeof x?\"undefined\":_typeof(x))&&null!==x||\"function\"==typeof x},exports.toInteger=function(v){return v=Number(v),isNaN(v)?0:v<0?-1*Math.floor(Math.abs(v)):Math.floor(Math.abs(v))},exports.createDataProperty=function(o,p,v){assert(exports.typeIsObject(o)),o[p]=v},exports.createArrayFromList=function(elements){return elements.slice()},exports.ArrayBufferCopy=function(dest,destOffset,src,srcOffset,n){new Uint8Array(dest).set(new Uint8Array(src,srcOffset,n),destOffset)},exports.CreateIterResultObject=function(value,done){return assert(\"boolean\"==typeof done),{value:value,done:done}},exports.IsFiniteNonNegativeNumber=function(v){return!Number.isNaN(v)&&(v!==+(1/0)&&!(v<0))},exports.InvokeOrNoop=function(O,P,args){var method=O[P];if(void 0!==method)return method.apply(O,args)},exports.PromiseInvokeOrNoop=function(O,P,args){var method=void 0;try{return method=O[P],void 0===method?Promise.resolve(void 0):Promise.resolve(method.apply(O,args))}catch(e){return Promise.reject(e)}},exports.PromiseInvokeOrFallbackOrNoop=function(O,P1,args1,P2,args2){var method=void 0;try{method=O[P1]}catch(methodE){return Promise.reject(methodE)}if(void 0===method)return exports.PromiseInvokeOrNoop(O,P2,args2);try{return Promise.resolve(method.apply(O,args1))}catch(e){return Promise.reject(e)}},exports.SameRealmTransfer=function(O){return O},exports.ValidateAndNormalizeHighWaterMark=function(highWaterMark){if(highWaterMark=Number(highWaterMark),Number.isNaN(highWaterMark)||highWaterMark<0)throw new RangeError(\"highWaterMark property of a queuing strategy must be nonnegative and non-NaN\");return highWaterMark},exports.ValidateAndNormalizeQueuingStrategy=function(size,highWaterMark){if(void 0!==size&&\"function\"!=typeof size)throw new TypeError(\"size property of a queuing strategy must be a function\");return highWaterMark=exports.ValidateAndNormalizeHighWaterMark(highWaterMark),{size:size,highWaterMark:highWaterMark}}},{assert:2}],10:[function(require,module,exports){\"use strict\";var assert=require(\"assert\"),_require=require(\"./helpers.js\"),IsFiniteNonNegativeNumber=_require.IsFiniteNonNegativeNumber;exports.DequeueValue=function(queue){assert(queue.length>0,\"Spec-level failure: should never dequeue from an empty queue.\");var pair=queue.shift();return pair.value},exports.EnqueueValueWithSize=function(queue,value,size){if(size=Number(size),!IsFiniteNonNegativeNumber(size))throw new RangeError(\"Size must be a finite, non-NaN, non-negative number.\");queue.push({value:value,size:size})},exports.GetTotalQueueSize=function(queue){var totalSize=0;return queue.forEach(function(pair){assert(\"number\"==typeof pair.size&&!Number.isNaN(pair.size)&&pair.size!==+(1/0)&&pair.size!==-(1/0),\"Spec-level failure: should never find an invalid size in the queue.\"),totalSize+=pair.size}),totalSize},exports.PeekQueueValue=function(queue){assert(queue.length>0,\"Spec-level failure: should never peek at an empty queue.\");var pair=queue[0];return pair.value}},{\"./helpers.js\":9,assert:2}],11:[function(require,module,exports){\"use strict\";function _classCallCheck(instance,Constructor){if(!(instance instanceof Constructor))throw new TypeError(\"Cannot call a class as a function\")}function AcquireReadableStreamBYOBReader(stream){return new ReadableStreamBYOBReader(stream)}function AcquireReadableStreamDefaultReader(stream){return new ReadableStreamDefaultReader(stream)}function IsReadableStream(x){return!!typeIsObject(x)&&!!Object.prototype.hasOwnProperty.call(x,\"_readableStreamController\")}function IsReadableStreamDisturbed(stream){return assert(IsReadableStream(stream)===!0,\"IsReadableStreamDisturbed should only be used on known readable streams\"),stream._disturbed}function IsReadableStreamLocked(stream){return assert(IsReadableStream(stream)===!0,\"IsReadableStreamLocked should only be used on known readable streams\"),void 0!==stream._reader}function ReadableStreamTee(stream,shouldClone){assert(IsReadableStream(stream)===!0),assert(\"boolean\"==typeof shouldClone);var reader=AcquireReadableStreamDefaultReader(stream),teeState={closedOrErrored:!1,canceled1:!1,canceled2:!1,reason1:void 0,reason2:void 0};teeState.promise=new Promise(function(resolve){return teeState._resolve=resolve});var pull=create_ReadableStreamTeePullFunction();pull._reader=reader,pull._teeState=teeState,pull._shouldClone=shouldClone;var cancel1=create_ReadableStreamTeeBranch1CancelFunction();cancel1._stream=stream,cancel1._teeState=teeState;var cancel2=create_ReadableStreamTeeBranch2CancelFunction();cancel2._stream=stream,cancel2._teeState=teeState;var underlyingSource1=Object.create(Object.prototype);createDataProperty(underlyingSource1,\"pull\",pull),createDataProperty(underlyingSource1,\"cancel\",cancel1);var branch1Stream=new ReadableStream(underlyingSource1),underlyingSource2=Object.create(Object.prototype);createDataProperty(underlyingSource2,\"pull\",pull),createDataProperty(underlyingSource2,\"cancel\",cancel2);var branch2Stream=new ReadableStream(underlyingSource2);return pull._branch1=branch1Stream._readableStreamController,pull._branch2=branch2Stream._readableStreamController,reader._closedPromise.catch(function(r){teeState.closedOrErrored!==!0&&(ReadableStreamDefaultControllerError(pull._branch1,r),ReadableStreamDefaultControllerError(pull._branch2,r),teeState.closedOrErrored=!0)}),[branch1Stream,branch2Stream]}function create_ReadableStreamTeePullFunction(){var f=function f(){var reader=f._reader,branch1=f._branch1,branch2=f._branch2,teeState=f._teeState;f._shouldClone;return ReadableStreamDefaultReaderRead(reader).then(function(result){assert(typeIsObject(result));var value=result.value,done=result.done;if(assert(\"boolean\"==typeof done),done===!0&&teeState.closedOrErrored===!1&&(teeState.canceled1===!1&&ReadableStreamDefaultControllerClose(branch1),teeState.canceled2===!1&&ReadableStreamDefaultControllerClose(branch2),teeState.closedOrErrored=!0),teeState.closedOrErrored!==!0){if(teeState.canceled1===!1){var value1=value;ReadableStreamDefaultControllerEnqueue(branch1,value1)}if(teeState.canceled2===!1){var value2=value;ReadableStreamDefaultControllerEnqueue(branch2,value2)}}})};return f}function create_ReadableStreamTeeBranch1CancelFunction(){var f=function f(reason){var stream=f._stream,teeState=f._teeState;if(teeState.canceled1=!0,teeState.reason1=reason,teeState.canceled2===!0){var compositeReason=createArrayFromList([teeState.reason1,teeState.reason2]),cancelResult=ReadableStreamCancel(stream,compositeReason);teeState._resolve(cancelResult)}return teeState.promise};return f}function create_ReadableStreamTeeBranch2CancelFunction(){var f=function f(reason){var stream=f._stream,teeState=f._teeState;if(teeState.canceled2=!0,teeState.reason2=reason,teeState.canceled1===!0){var compositeReason=createArrayFromList([teeState.reason1,teeState.reason2]),cancelResult=ReadableStreamCancel(stream,compositeReason);teeState._resolve(cancelResult)}return teeState.promise};return f}function ReadableStreamAddReadIntoRequest(stream){assert(IsReadableStreamBYOBReader(stream._reader)===!0),assert(\"readable\"===stream._state||\"closed\"===stream._state);var promise=new Promise(function(resolve,reject){var readIntoRequest={_resolve:resolve,_reject:reject};stream._reader._readIntoRequests.push(readIntoRequest)});return promise}function ReadableStreamAddReadRequest(stream){assert(IsReadableStreamDefaultReader(stream._reader)===!0),assert(\"readable\"===stream._state);var promise=new Promise(function(resolve,reject){var readRequest={_resolve:resolve,_reject:reject};stream._reader._readRequests.push(readRequest)});return promise}function ReadableStreamCancel(stream,reason){if(stream._disturbed=!0,\"closed\"===stream._state)return Promise.resolve(void 0);if(\"errored\"===stream._state)return Promise.reject(stream._storedError);ReadableStreamClose(stream);var sourceCancelPromise=stream._readableStreamController[InternalCancel](reason);return sourceCancelPromise.then(function(){})}function ReadableStreamClose(stream){assert(\"readable\"===stream._state),stream._state=\"closed\";var reader=stream._reader;if(void 0!==reader){if(IsReadableStreamDefaultReader(reader)===!0){var _iteratorNormalCompletion=!0,_didIteratorError=!1,_iteratorError=void 0;try{for(var _step,_iterator=reader._readRequests[Symbol.iterator]();!(_iteratorNormalCompletion=(_step=_iterator.next()).done);_iteratorNormalCompletion=!0){var _resolve=_step.value._resolve;_resolve(CreateIterResultObject(void 0,!0))}}catch(err){_didIteratorError=!0,_iteratorError=err}finally{try{!_iteratorNormalCompletion&&_iterator.return&&_iterator.return()}finally{if(_didIteratorError)throw _iteratorError}}reader._readRequests=[]}reader._closedPromise_resolve(void 0),reader._closedPromise_resolve=void 0,reader._closedPromise_reject=void 0}}function ReadableStreamError(stream,e){assert(IsReadableStream(stream)===!0,\"stream must be ReadableStream\"),assert(\"readable\"===stream._state,\"state must be readable\"),stream._state=\"errored\",stream._storedError=e;var reader=stream._reader;if(void 0!==reader){if(IsReadableStreamDefaultReader(reader)===!0){var _iteratorNormalCompletion2=!0,_didIteratorError2=!1,_iteratorError2=void 0;try{for(var _step2,_iterator2=reader._readRequests[Symbol.iterator]();!(_iteratorNormalCompletion2=(_step2=_iterator2.next()).done);_iteratorNormalCompletion2=!0){var readRequest=_step2.value;readRequest._reject(e)}}catch(err){_didIteratorError2=!0,_iteratorError2=err}finally{try{!_iteratorNormalCompletion2&&_iterator2.return&&_iterator2.return()}finally{if(_didIteratorError2)throw _iteratorError2}}reader._readRequests=[]}else{assert(IsReadableStreamBYOBReader(reader),\"reader must be ReadableStreamBYOBReader\");var _iteratorNormalCompletion3=!0,_didIteratorError3=!1,_iteratorError3=void 0;try{for(var _step3,_iterator3=reader._readIntoRequests[Symbol.iterator]();!(_iteratorNormalCompletion3=(_step3=_iterator3.next()).done);_iteratorNormalCompletion3=!0){var readIntoRequest=_step3.value;readIntoRequest._reject(e)}}catch(err){_didIteratorError3=!0,_iteratorError3=err}finally{try{!_iteratorNormalCompletion3&&_iterator3.return&&_iterator3.return()}finally{if(_didIteratorError3)throw _iteratorError3}}reader._readIntoRequests=[]}reader._closedPromise_reject(e),reader._closedPromise_resolve=void 0,reader._closedPromise_reject=void 0}}function ReadableStreamFulfillReadIntoRequest(stream,chunk,done){var reader=stream._reader;assert(reader._readIntoRequests.length>0);var readIntoRequest=reader._readIntoRequests.shift();readIntoRequest._resolve(CreateIterResultObject(chunk,done))}function ReadableStreamFulfillReadRequest(stream,chunk,done){var reader=stream._reader;assert(reader._readRequests.length>0);var readRequest=reader._readRequests.shift();readRequest._resolve(CreateIterResultObject(chunk,done))}function ReadableStreamGetNumReadIntoRequests(stream){return stream._reader._readIntoRequests.length}function ReadableStreamGetNumReadRequests(stream){return stream._reader._readRequests.length;\n}function ReadableStreamHasBYOBReader(stream){var reader=stream._reader;return void 0!==reader&&IsReadableStreamBYOBReader(reader)!==!1}function ReadableStreamHasDefaultReader(stream){var reader=stream._reader;return void 0!==reader&&IsReadableStreamDefaultReader(reader)!==!1}function IsReadableStreamBYOBReader(x){return!!typeIsObject(x)&&!!Object.prototype.hasOwnProperty.call(x,\"_readIntoRequests\")}function IsReadableStreamDefaultReader(x){return!!typeIsObject(x)&&!!Object.prototype.hasOwnProperty.call(x,\"_readRequests\")}function ReadableStreamReaderGenericInitialize(reader,stream){reader._ownerReadableStream=stream,stream._reader=reader,\"readable\"===stream._state?reader._closedPromise=new Promise(function(resolve,reject){reader._closedPromise_resolve=resolve,reader._closedPromise_reject=reject}):\"closed\"===stream._state?(reader._closedPromise=Promise.resolve(void 0),reader._closedPromise_resolve=void 0,reader._closedPromise_reject=void 0):(assert(\"errored\"===stream._state,\"state must be errored\"),reader._closedPromise=Promise.reject(stream._storedError),reader._closedPromise_resolve=void 0,reader._closedPromise_reject=void 0)}function ReadableStreamReaderGenericCancel(reader,reason){var stream=reader._ownerReadableStream;return assert(void 0!==stream),ReadableStreamCancel(stream,reason)}function ReadableStreamReaderGenericRelease(reader){assert(void 0!==reader._ownerReadableStream),assert(reader._ownerReadableStream._reader===reader),\"readable\"===reader._ownerReadableStream._state?reader._closedPromise_reject(new TypeError(\"Reader was released and can no longer be used to monitor the stream's closedness\")):reader._closedPromise=Promise.reject(new TypeError(\"Reader was released and can no longer be used to monitor the stream's closedness\")),reader._ownerReadableStream._reader=void 0,reader._ownerReadableStream=void 0}function ReadableStreamBYOBReaderRead(reader,view){var stream=reader._ownerReadableStream;return assert(void 0!==stream),stream._disturbed=!0,\"errored\"===stream._state?Promise.reject(stream._storedError):ReadableByteStreamControllerPullInto(stream._readableStreamController,view)}function ReadableStreamDefaultReaderRead(reader){var stream=reader._ownerReadableStream;return assert(void 0!==stream),stream._disturbed=!0,\"closed\"===stream._state?Promise.resolve(CreateIterResultObject(void 0,!0)):\"errored\"===stream._state?Promise.reject(stream._storedError):(assert(\"readable\"===stream._state),stream._readableStreamController[InternalPull]())}function IsReadableStreamDefaultController(x){return!!typeIsObject(x)&&!!Object.prototype.hasOwnProperty.call(x,\"_underlyingSource\")}function ReadableStreamDefaultControllerCallPullIfNeeded(controller){var shouldPull=ReadableStreamDefaultControllerShouldCallPull(controller);if(shouldPull!==!1){if(controller._pulling===!0)return void(controller._pullAgain=!0);controller._pulling=!0;var pullPromise=PromiseInvokeOrNoop(controller._underlyingSource,\"pull\",[controller]);pullPromise.then(function(){if(controller._pulling=!1,controller._pullAgain===!0)return controller._pullAgain=!1,ReadableStreamDefaultControllerCallPullIfNeeded(controller)},function(e){if(\"readable\"===controller._controlledReadableStream._state)return ReadableStreamDefaultControllerError(controller,e)}).catch(rethrowAssertionErrorRejection)}}function ReadableStreamDefaultControllerShouldCallPull(controller){var stream=controller._controlledReadableStream;if(\"closed\"===stream._state||\"errored\"===stream._state)return!1;if(controller._closeRequested===!0)return!1;if(controller._started===!1)return!1;if(IsReadableStreamLocked(stream)===!0&&ReadableStreamGetNumReadRequests(stream)>0)return!0;var desiredSize=ReadableStreamDefaultControllerGetDesiredSize(controller);return desiredSize>0}function ReadableStreamDefaultControllerClose(controller){var stream=controller._controlledReadableStream;assert(controller._closeRequested===!1),assert(\"readable\"===stream._state),controller._closeRequested=!0,0===controller._queue.length&&ReadableStreamClose(stream)}function ReadableStreamDefaultControllerEnqueue(controller,chunk){var stream=controller._controlledReadableStream;if(assert(controller._closeRequested===!1),assert(\"readable\"===stream._state),IsReadableStreamLocked(stream)===!0&&ReadableStreamGetNumReadRequests(stream)>0)ReadableStreamFulfillReadRequest(stream,chunk,!1);else{var chunkSize=1;if(void 0!==controller._strategySize)try{chunkSize=controller._strategySize(chunk)}catch(chunkSizeE){throw\"readable\"===stream._state&&ReadableStreamDefaultControllerError(controller,chunkSizeE),chunkSizeE}try{EnqueueValueWithSize(controller._queue,chunk,chunkSize)}catch(enqueueE){throw\"readable\"===stream._state&&ReadableStreamDefaultControllerError(controller,enqueueE),enqueueE}}ReadableStreamDefaultControllerCallPullIfNeeded(controller)}function ReadableStreamDefaultControllerError(controller,e){var stream=controller._controlledReadableStream;assert(\"readable\"===stream._state),controller._queue=[],ReadableStreamError(stream,e)}function ReadableStreamDefaultControllerGetDesiredSize(controller){var queueSize=GetTotalQueueSize(controller._queue);return controller._strategyHWM-queueSize}function IsReadableByteStreamController(x){return!!typeIsObject(x)&&!!Object.prototype.hasOwnProperty.call(x,\"_underlyingByteSource\")}function IsReadableStreamBYOBRequest(x){return!!typeIsObject(x)&&!!Object.prototype.hasOwnProperty.call(x,\"_associatedReadableByteStreamController\")}function ReadableByteStreamControllerCallPullIfNeeded(controller){var shouldPull=ReadableByteStreamControllerShouldCallPull(controller);if(shouldPull!==!1){if(controller._pulling===!0)return void(controller._pullAgain=!0);controller._pullAgain=!1,controller._pulling=!0;var pullPromise=PromiseInvokeOrNoop(controller._underlyingByteSource,\"pull\",[controller]);pullPromise.then(function(){controller._pulling=!1,controller._pullAgain===!0&&(controller._pullAgain=!1,ReadableByteStreamControllerCallPullIfNeeded(controller))},function(e){\"readable\"===controller._controlledReadableStream._state&&ReadableByteStreamControllerError(controller,e)}).catch(rethrowAssertionErrorRejection)}}function ReadableByteStreamControllerClearPendingPullIntos(controller){ReadableByteStreamControllerInvalidateBYOBRequest(controller),controller._pendingPullIntos=[]}function ReadableByteStreamControllerCommitPullIntoDescriptor(stream,pullIntoDescriptor){assert(\"errored\"!==stream._state,\"state must not be errored\");var done=!1;\"closed\"===stream._state&&(assert(0===pullIntoDescriptor.bytesFilled),done=!0);var filledView=ReadableByteStreamControllerConvertPullIntoDescriptor(pullIntoDescriptor);\"default\"===pullIntoDescriptor.readerType?ReadableStreamFulfillReadRequest(stream,filledView,done):(assert(\"byob\"===pullIntoDescriptor.readerType),ReadableStreamFulfillReadIntoRequest(stream,filledView,done))}function ReadableByteStreamControllerConvertPullIntoDescriptor(pullIntoDescriptor){var bytesFilled=pullIntoDescriptor.bytesFilled,elementSize=pullIntoDescriptor.elementSize;return assert(bytesFilled<=pullIntoDescriptor.byteLength),assert(bytesFilled%elementSize===0),new pullIntoDescriptor.ctor(pullIntoDescriptor.buffer,pullIntoDescriptor.byteOffset,bytesFilled/elementSize)}function ReadableByteStreamControllerEnqueueChunkToQueue(controller,buffer,byteOffset,byteLength){controller._queue.push({buffer:buffer,byteOffset:byteOffset,byteLength:byteLength}),controller._totalQueuedBytes+=byteLength}function ReadableByteStreamControllerFillPullIntoDescriptorFromQueue(controller,pullIntoDescriptor){var elementSize=pullIntoDescriptor.elementSize,currentAlignedBytes=pullIntoDescriptor.bytesFilled-pullIntoDescriptor.bytesFilled%elementSize,maxBytesToCopy=Math.min(controller._totalQueuedBytes,pullIntoDescriptor.byteLength-pullIntoDescriptor.bytesFilled),maxBytesFilled=pullIntoDescriptor.bytesFilled+maxBytesToCopy,maxAlignedBytes=maxBytesFilled-maxBytesFilled%elementSize,totalBytesToCopyRemaining=maxBytesToCopy,ready=!1;maxAlignedBytes>currentAlignedBytes&&(totalBytesToCopyRemaining=maxAlignedBytes-pullIntoDescriptor.bytesFilled,ready=!0);for(var queue=controller._queue;totalBytesToCopyRemaining>0;){var headOfQueue=queue[0],bytesToCopy=Math.min(totalBytesToCopyRemaining,headOfQueue.byteLength),destStart=pullIntoDescriptor.byteOffset+pullIntoDescriptor.bytesFilled;ArrayBufferCopy(pullIntoDescriptor.buffer,destStart,headOfQueue.buffer,headOfQueue.byteOffset,bytesToCopy),headOfQueue.byteLength===bytesToCopy?queue.shift():(headOfQueue.byteOffset+=bytesToCopy,headOfQueue.byteLength-=bytesToCopy),controller._totalQueuedBytes-=bytesToCopy,ReadableByteStreamControllerFillHeadPullIntoDescriptor(controller,bytesToCopy,pullIntoDescriptor),totalBytesToCopyRemaining-=bytesToCopy}return ready===!1&&(assert(0===controller._totalQueuedBytes,\"queue must be empty\"),assert(pullIntoDescriptor.bytesFilled>0),assert(pullIntoDescriptor.bytesFilled0;){if(0===controller._totalQueuedBytes)return;var pullIntoDescriptor=controller._pendingPullIntos[0];ReadableByteStreamControllerFillPullIntoDescriptorFromQueue(controller,pullIntoDescriptor)===!0&&(ReadableByteStreamControllerShiftPendingPullInto(controller),ReadableByteStreamControllerCommitPullIntoDescriptor(controller._controlledReadableStream,pullIntoDescriptor))}}function ReadableByteStreamControllerPullInto(controller,view){var stream=controller._controlledReadableStream,elementSize=1;view.constructor!==DataView&&(elementSize=view.constructor.BYTES_PER_ELEMENT);var ctor=view.constructor,pullIntoDescriptor={buffer:view.buffer,byteOffset:view.byteOffset,byteLength:view.byteLength,bytesFilled:0,elementSize:elementSize,ctor:ctor,readerType:\"byob\"};if(controller._pendingPullIntos.length>0)return pullIntoDescriptor.buffer=SameRealmTransfer(pullIntoDescriptor.buffer),controller._pendingPullIntos.push(pullIntoDescriptor),ReadableStreamAddReadIntoRequest(stream);if(\"closed\"===stream._state){var emptyView=new view.constructor(view.buffer,view.byteOffset,0);return Promise.resolve(CreateIterResultObject(emptyView,!0))}if(controller._totalQueuedBytes>0){if(ReadableByteStreamControllerFillPullIntoDescriptorFromQueue(controller,pullIntoDescriptor)===!0){var filledView=ReadableByteStreamControllerConvertPullIntoDescriptor(pullIntoDescriptor);return ReadableByteStreamControllerHandleQueueDrain(controller),Promise.resolve(CreateIterResultObject(filledView,!1))}if(controller._closeRequested===!0){var e=new TypeError(\"Insufficient bytes to fill elements in the given buffer\");return ReadableByteStreamControllerError(controller,e),Promise.reject(e)}}pullIntoDescriptor.buffer=SameRealmTransfer(pullIntoDescriptor.buffer),controller._pendingPullIntos.push(pullIntoDescriptor);var promise=ReadableStreamAddReadIntoRequest(stream);return ReadableByteStreamControllerCallPullIfNeeded(controller),promise}function ReadableByteStreamControllerRespondInClosedState(controller,firstDescriptor){firstDescriptor.buffer=SameRealmTransfer(firstDescriptor.buffer),assert(0===firstDescriptor.bytesFilled,\"bytesFilled must be 0\");for(var stream=controller._controlledReadableStream;ReadableStreamGetNumReadIntoRequests(stream)>0;){var pullIntoDescriptor=ReadableByteStreamControllerShiftPendingPullInto(controller);ReadableByteStreamControllerCommitPullIntoDescriptor(stream,pullIntoDescriptor)}}function ReadableByteStreamControllerRespondInReadableState(controller,bytesWritten,pullIntoDescriptor){if(pullIntoDescriptor.bytesFilled+bytesWritten>pullIntoDescriptor.byteLength)throw new RangeError(\"bytesWritten out of range\");if(ReadableByteStreamControllerFillHeadPullIntoDescriptor(controller,bytesWritten,pullIntoDescriptor),!(pullIntoDescriptor.bytesFilled0){var end=pullIntoDescriptor.byteOffset+pullIntoDescriptor.bytesFilled,remainder=pullIntoDescriptor.buffer.slice(end-remainderSize,end);ReadableByteStreamControllerEnqueueChunkToQueue(controller,remainder,0,remainder.byteLength)}pullIntoDescriptor.buffer=SameRealmTransfer(pullIntoDescriptor.buffer),pullIntoDescriptor.bytesFilled-=remainderSize,ReadableByteStreamControllerCommitPullIntoDescriptor(controller._controlledReadableStream,pullIntoDescriptor),ReadableByteStreamControllerProcessPullIntoDescriptorsUsingQueue(controller)}}function ReadableByteStreamControllerRespondInternal(controller,bytesWritten){var firstDescriptor=controller._pendingPullIntos[0],stream=controller._controlledReadableStream;if(\"closed\"===stream._state){if(0!==bytesWritten)throw new TypeError(\"bytesWritten must be 0 when calling respond() on a closed stream\");ReadableByteStreamControllerRespondInClosedState(controller,firstDescriptor)}else assert(\"readable\"===stream._state),ReadableByteStreamControllerRespondInReadableState(controller,bytesWritten,firstDescriptor)}function ReadableByteStreamControllerShiftPendingPullInto(controller){var descriptor=controller._pendingPullIntos.shift();return ReadableByteStreamControllerInvalidateBYOBRequest(controller),descriptor}function ReadableByteStreamControllerShouldCallPull(controller){var stream=controller._controlledReadableStream;return\"readable\"===stream._state&&(controller._closeRequested!==!0&&(controller._started!==!1&&(!!(ReadableStreamHasDefaultReader(stream)&&ReadableStreamGetNumReadRequests(stream)>0)||(!!(ReadableStreamHasBYOBReader(stream)&&ReadableStreamGetNumReadIntoRequests(stream)>0)||ReadableByteStreamControllerGetDesiredSize(controller)>0))))}function ReadableByteStreamControllerClose(controller){var stream=controller._controlledReadableStream;if(assert(controller._closeRequested===!1),assert(\"readable\"===stream._state),controller._totalQueuedBytes>0)return void(controller._closeRequested=!0);if(controller._pendingPullIntos.length>0){var firstPendingPullInto=controller._pendingPullIntos[0];if(firstPendingPullInto.bytesFilled>0){var e=new TypeError(\"Insufficient bytes to fill elements in the given buffer\");throw ReadableByteStreamControllerError(controller,e),e}}ReadableStreamClose(stream)}function ReadableByteStreamControllerEnqueue(controller,chunk){var stream=controller._controlledReadableStream;assert(controller._closeRequested===!1),assert(\"readable\"===stream._state);var buffer=chunk.buffer,byteOffset=chunk.byteOffset,byteLength=chunk.byteLength,transferredBuffer=SameRealmTransfer(buffer);if(ReadableStreamHasDefaultReader(stream)===!0)if(0===ReadableStreamGetNumReadRequests(stream))ReadableByteStreamControllerEnqueueChunkToQueue(controller,transferredBuffer,byteOffset,byteLength);else{assert(0===controller._queue.length);var transferredView=new Uint8Array(transferredBuffer,byteOffset,byteLength);ReadableStreamFulfillReadRequest(stream,transferredView,!1)}else ReadableStreamHasBYOBReader(stream)===!0?(ReadableByteStreamControllerEnqueueChunkToQueue(controller,transferredBuffer,byteOffset,byteLength),ReadableByteStreamControllerProcessPullIntoDescriptorsUsingQueue(controller)):(assert(IsReadableStreamLocked(stream)===!1,\"stream must not be locked\"),ReadableByteStreamControllerEnqueueChunkToQueue(controller,transferredBuffer,byteOffset,byteLength))}function ReadableByteStreamControllerError(controller,e){var stream=controller._controlledReadableStream;assert(\"readable\"===stream._state),ReadableByteStreamControllerClearPendingPullIntos(controller),controller._queue=[],ReadableStreamError(stream,e)}function ReadableByteStreamControllerGetDesiredSize(controller){return controller._strategyHWM-controller._totalQueuedBytes}function ReadableByteStreamControllerRespond(controller,bytesWritten){if(bytesWritten=Number(bytesWritten),IsFiniteNonNegativeNumber(bytesWritten)===!1)throw new RangeError(\"bytesWritten must be a finite\");assert(controller._pendingPullIntos.length>0),ReadableByteStreamControllerRespondInternal(controller,bytesWritten)}function ReadableByteStreamControllerRespondWithNewView(controller,view){assert(controller._pendingPullIntos.length>0);var firstDescriptor=controller._pendingPullIntos[0];if(firstDescriptor.byteOffset+firstDescriptor.bytesFilled!==view.byteOffset)throw new RangeError(\"The region specified by view does not match byobRequest\");if(firstDescriptor.byteLength!==view.byteLength)throw new RangeError(\"The buffer of view has different capacity than byobRequest\");firstDescriptor.buffer=view.buffer,ReadableByteStreamControllerRespondInternal(controller,view.byteLength)}var _slicedToArray=function(){function sliceIterator(arr,i){var _arr=[],_n=!0,_d=!1,_e=void 0;try{for(var _s,_i=arr[Symbol.iterator]();!(_n=(_s=_i.next()).done)&&(_arr.push(_s.value),!i||_arr.length!==i);_n=!0);}catch(err){_d=!0,_e=err}finally{try{!_n&&_i.return&&_i.return()}finally{if(_d)throw _e}}return _arr}return function(arr,i){if(Array.isArray(arr))return arr;if(Symbol.iterator in Object(arr))return sliceIterator(arr,i);throw new TypeError(\"Invalid attempt to destructure non-iterable instance\")}}(),_createClass=function(){function defineProperties(target,props){for(var i=0;i0)throw new TypeError(\"Tried to release a reader lock when that reader has pending read() calls un-settled\");ReadableStreamReaderGenericRelease(this)}}},{key:\"closed\",get:function(){return IsReadableStreamDefaultReader(this)===!1?Promise.reject(new TypeError(\"ReadableStreamDefaultReader.prototype.closed can only be used on a ReadableStreamDefaultReader\")):this._closedPromise}}]),ReadableStreamDefaultReader}(),ReadableStreamBYOBReader=function(){function ReadableStreamBYOBReader(stream){if(_classCallCheck(this,ReadableStreamBYOBReader),!IsReadableStream(stream))throw new TypeError(\"ReadableStreamBYOBReader can only be constructed with a ReadableStream instance given a byte source\");if(IsReadableStreamLocked(stream))throw new TypeError(\"This stream has already been locked for exclusive reading by another reader\");ReadableStreamReaderGenericInitialize(this,stream),this._readIntoRequests=[]}return _createClass(ReadableStreamBYOBReader,[{key:\"cancel\",value:function(reason){return IsReadableStreamBYOBReader(this)?void 0===this._ownerReadableStream?Promise.reject(new TypeError(\"Cannot cancel a stream using a released reader\")):ReadableStreamReaderGenericCancel(this,reason):Promise.reject(new TypeError(\"ReadableStreamBYOBReader.prototype.cancel can only be used on a ReadableStreamBYOBReader\"))}},{key:\"read\",value:function(view){return IsReadableStreamBYOBReader(this)?void 0===this._ownerReadableStream?Promise.reject(new TypeError(\"Cannot read from a released reader\")):ArrayBuffer.isView(view)?0===view.byteLength?Promise.reject(new TypeError(\"view must have non-zero byteLength\")):ReadableStreamBYOBReaderRead(this,view):Promise.reject(new TypeError(\"view must be an array buffer view\")):Promise.reject(new TypeError(\"ReadableStreamBYOBReader.prototype.read can only be used on a ReadableStreamBYOBReader\"))}},{key:\"releaseLock\",value:function(){if(!IsReadableStreamBYOBReader(this))throw new TypeError(\"ReadableStreamBYOBReader.prototype.releaseLock can only be used on a ReadableStreamBYOBReader\");if(void 0!==this._ownerReadableStream){if(this._readIntoRequests.length>0)throw new TypeError(\"Tried to release a reader lock when that reader has pending read() calls un-settled\");ReadableStreamReaderGenericRelease(this)}}},{key:\"closed\",get:function(){return IsReadableStreamBYOBReader(this)?this._closedPromise:Promise.reject(new TypeError(\"ReadableStreamBYOBReader.prototype.closed can only be used on a ReadableStreamBYOBReader\"))}}]),ReadableStreamBYOBReader}(),ReadableStreamDefaultController=function(){function ReadableStreamDefaultController(stream,underlyingSource,size,highWaterMark){if(_classCallCheck(this,ReadableStreamDefaultController),IsReadableStream(stream)===!1)throw new TypeError(\"ReadableStreamDefaultController can only be constructed with a ReadableStream instance\");if(void 0!==stream._readableStreamController)throw new TypeError(\"ReadableStreamDefaultController instances can only be created by the ReadableStream constructor\");this._controlledReadableStream=stream,this._underlyingSource=underlyingSource,this._queue=[],this._started=!1,this._closeRequested=!1,this._pullAgain=!1,this._pulling=!1;var normalizedStrategy=ValidateAndNormalizeQueuingStrategy(size,highWaterMark);this._strategySize=normalizedStrategy.size,this._strategyHWM=normalizedStrategy.highWaterMark;var controller=this,startResult=InvokeOrNoop(underlyingSource,\"start\",[this]);Promise.resolve(startResult).then(function(){controller._started=!0,ReadableStreamDefaultControllerCallPullIfNeeded(controller)},function(r){\"readable\"===stream._state&&ReadableStreamDefaultControllerError(controller,r)}).catch(rethrowAssertionErrorRejection)}return _createClass(ReadableStreamDefaultController,[{key:\"close\",value:function(){if(IsReadableStreamDefaultController(this)===!1)throw new TypeError(\"ReadableStreamDefaultController.prototype.close can only be used on a ReadableStreamDefaultController\");if(this._closeRequested===!0)throw new TypeError(\"The stream has already been closed; do not close it again!\");var state=this._controlledReadableStream._state;if(\"readable\"!==state)throw new TypeError(\"The stream (in \"+state+\" state) is not in the readable state and cannot be closed\");ReadableStreamDefaultControllerClose(this)}},{key:\"enqueue\",value:function(chunk){if(IsReadableStreamDefaultController(this)===!1)throw new TypeError(\"ReadableStreamDefaultController.prototype.enqueue can only be used on a ReadableStreamDefaultController\");if(this._closeRequested===!0)throw new TypeError(\"stream is closed or draining\");var state=this._controlledReadableStream._state;if(\"readable\"!==state)throw new TypeError(\"The stream (in \"+state+\" state) is not in the readable state and cannot be enqueued to\");return ReadableStreamDefaultControllerEnqueue(this,chunk)}},{key:\"error\",value:function(e){if(IsReadableStreamDefaultController(this)===!1)throw new TypeError(\"ReadableStreamDefaultController.prototype.error can only be used on a ReadableStreamDefaultController\");var stream=this._controlledReadableStream;if(\"readable\"!==stream._state)throw new TypeError(\"The stream is \"+stream._state+\" and so cannot be errored\");ReadableStreamDefaultControllerError(this,e)}},{key:InternalCancel,value:function(reason){return this._queue=[],PromiseInvokeOrNoop(this._underlyingSource,\"cancel\",[reason])}},{key:InternalPull,value:function(){var stream=this._controlledReadableStream;if(this._queue.length>0){var chunk=DequeueValue(this._queue);return this._closeRequested===!0&&0===this._queue.length?ReadableStreamClose(stream):ReadableStreamDefaultControllerCallPullIfNeeded(this),Promise.resolve(CreateIterResultObject(chunk,!1))}var pendingPromise=ReadableStreamAddReadRequest(stream);return ReadableStreamDefaultControllerCallPullIfNeeded(this),pendingPromise}},{key:\"desiredSize\",get:function(){if(IsReadableStreamDefaultController(this)===!1)throw new TypeError(\"ReadableStreamDefaultController.prototype.desiredSize can only be used on a ReadableStreamDefaultController\");return ReadableStreamDefaultControllerGetDesiredSize(this)}}]),ReadableStreamDefaultController}(),ReadableStreamBYOBRequest=function(){function ReadableStreamBYOBRequest(controller,view){_classCallCheck(this,ReadableStreamBYOBRequest),this._associatedReadableByteStreamController=controller,this._view=view}return _createClass(ReadableStreamBYOBRequest,[{key:\"respond\",value:function(bytesWritten){if(IsReadableStreamBYOBRequest(this)===!1)throw new TypeError(\"ReadableByteStreamController.prototype.respond can only be used on a ReadableByteStreamController\");if(void 0===this._associatedReadableByteStreamController)throw new TypeError(\"This BYOB request has been invalidated\");ReadableByteStreamControllerRespond(this._associatedReadableByteStreamController,bytesWritten);\n}},{key:\"respondWithNewView\",value:function(view){if(IsReadableStreamBYOBRequest(this)===!1)throw new TypeError(\"ReadableByteStreamController.prototype.respond can only be used on a ReadableByteStreamController\");if(void 0===this._associatedReadableByteStreamController)throw new TypeError(\"This BYOB request has been invalidated\");if(!ArrayBuffer.isView(view))throw new TypeError(\"You can only respond with array buffer views\");ReadableByteStreamControllerRespondWithNewView(this._associatedReadableByteStreamController,view)}},{key:\"view\",get:function(){return this._view}}]),ReadableStreamBYOBRequest}(),ReadableByteStreamController=function(){function ReadableByteStreamController(stream,underlyingByteSource,highWaterMark){if(_classCallCheck(this,ReadableByteStreamController),IsReadableStream(stream)===!1)throw new TypeError(\"ReadableByteStreamController can only be constructed with a ReadableStream instance given a byte source\");if(void 0!==stream._readableStreamController)throw new TypeError(\"ReadableByteStreamController instances can only be created by the ReadableStream constructor given a byte source\");this._controlledReadableStream=stream,this._underlyingByteSource=underlyingByteSource,this._pullAgain=!1,this._pulling=!1,ReadableByteStreamControllerClearPendingPullIntos(this),this._queue=[],this._totalQueuedBytes=0,this._closeRequested=!1,this._started=!1,this._strategyHWM=ValidateAndNormalizeHighWaterMark(highWaterMark);var autoAllocateChunkSize=underlyingByteSource.autoAllocateChunkSize;if(void 0!==autoAllocateChunkSize&&(Number.isInteger(autoAllocateChunkSize)===!1||autoAllocateChunkSize<0))throw new RangeError(\"autoAllocateChunkSize must be a non negative integer\");this._autoAllocateChunkSize=autoAllocateChunkSize,this._pendingPullIntos=[];var controller=this,startResult=InvokeOrNoop(underlyingByteSource,\"start\",[this]);Promise.resolve(startResult).then(function(){controller._started=!0,assert(controller._pulling===!1),assert(controller._pullAgain===!1),ReadableByteStreamControllerCallPullIfNeeded(controller)},function(r){\"readable\"===stream._state&&ReadableByteStreamControllerError(controller,r)}).catch(rethrowAssertionErrorRejection)}return _createClass(ReadableByteStreamController,[{key:\"close\",value:function(){if(IsReadableByteStreamController(this)===!1)throw new TypeError(\"ReadableByteStreamController.prototype.close can only be used on a ReadableByteStreamController\");if(this._closeRequested===!0)throw new TypeError(\"The stream has already been closed; do not close it again!\");var state=this._controlledReadableStream._state;if(\"readable\"!==state)throw new TypeError(\"The stream (in \"+state+\" state) is not in the readable state and cannot be closed\");ReadableByteStreamControllerClose(this)}},{key:\"enqueue\",value:function(chunk){if(IsReadableByteStreamController(this)===!1)throw new TypeError(\"ReadableByteStreamController.prototype.enqueue can only be used on a ReadableByteStreamController\");if(this._closeRequested===!0)throw new TypeError(\"stream is closed or draining\");var state=this._controlledReadableStream._state;if(\"readable\"!==state)throw new TypeError(\"The stream (in \"+state+\" state) is not in the readable state and cannot be enqueued to\");if(!ArrayBuffer.isView(chunk))throw new TypeError(\"You can only enqueue array buffer views when using a ReadableByteStreamController\");ReadableByteStreamControllerEnqueue(this,chunk)}},{key:\"error\",value:function(e){if(IsReadableByteStreamController(this)===!1)throw new TypeError(\"ReadableByteStreamController.prototype.error can only be used on a ReadableByteStreamController\");var stream=this._controlledReadableStream;if(\"readable\"!==stream._state)throw new TypeError(\"The stream is \"+stream._state+\" and so cannot be errored\");ReadableByteStreamControllerError(this,e)}},{key:InternalCancel,value:function(reason){if(this._pendingPullIntos.length>0){var firstDescriptor=this._pendingPullIntos[0];firstDescriptor.bytesFilled=0}return this._queue=[],this._totalQueuedBytes=0,PromiseInvokeOrNoop(this._underlyingByteSource,\"cancel\",[reason])}},{key:InternalPull,value:function(){var stream=this._controlledReadableStream;if(0===ReadableStreamGetNumReadRequests(stream)){if(this._totalQueuedBytes>0){var entry=this._queue.shift();this._totalQueuedBytes-=entry.byteLength,ReadableByteStreamControllerHandleQueueDrain(this);var view=void 0;try{view=new Uint8Array(entry.buffer,entry.byteOffset,entry.byteLength)}catch(viewE){return Promise.reject(viewE)}return Promise.resolve(CreateIterResultObject(view,!1))}var autoAllocateChunkSize=this._autoAllocateChunkSize;if(void 0!==autoAllocateChunkSize){var buffer=void 0;try{buffer=new ArrayBuffer(autoAllocateChunkSize)}catch(bufferE){return Promise.reject(bufferE)}var pullIntoDescriptor={buffer:buffer,byteOffset:0,byteLength:autoAllocateChunkSize,bytesFilled:0,elementSize:1,ctor:Uint8Array,readerType:\"default\"};this._pendingPullIntos.push(pullIntoDescriptor)}}else assert(void 0===this._autoAllocateChunkSize);var promise=ReadableStreamAddReadRequest(stream);return ReadableByteStreamControllerCallPullIfNeeded(this),promise}},{key:\"byobRequest\",get:function(){if(IsReadableByteStreamController(this)===!1)throw new TypeError(\"ReadableByteStreamController.prototype.byobRequest can only be used on a ReadableByteStreamController\");if(void 0===this._byobRequest&&this._pendingPullIntos.length>0){var firstDescriptor=this._pendingPullIntos[0],view=new Uint8Array(firstDescriptor.buffer,firstDescriptor.byteOffset+firstDescriptor.bytesFilled,firstDescriptor.byteLength-firstDescriptor.bytesFilled);this._byobRequest=new ReadableStreamBYOBRequest(this,view)}return this._byobRequest}},{key:\"desiredSize\",get:function(){if(IsReadableByteStreamController(this)===!1)throw new TypeError(\"ReadableByteStreamController.prototype.desiredSize can only be used on a ReadableByteStreamController\");return ReadableByteStreamControllerGetDesiredSize(this)}}]),ReadableByteStreamController}()},{\"./helpers.js\":9,\"./queue-with-sizes.js\":10,\"./utils.js\":13,assert:2}],12:[function(require,module,exports){\"use strict\";function _classCallCheck(instance,Constructor){if(!(instance instanceof Constructor))throw new TypeError(\"Cannot call a class as a function\")}var _require=require(\"./readable-stream.js\"),ReadableStream=_require.ReadableStream,_require2=require(\"./writable-stream.js\"),WritableStream=_require2.WritableStream;module.exports=function TransformStream(transformer){function maybeDoTransform(){if(transforming===!1){transforming=!0;try{transformer.transform(writeChunk,enqueueInReadable,transformDone),writeChunk=void 0,chunkWrittenButNotYetTransformed=!1}catch(e){transforming=!1,errorWritable(e),errorReadable(e)}}}function transformDone(){transforming=!1,writeDone()}if(_classCallCheck(this,TransformStream),void 0===transformer.flush&&(transformer.flush=function(enqueue,close){return close()}),\"function\"!=typeof transformer.transform)throw new TypeError(\"transform must be a function\");var writeChunk=void 0,writeDone=void 0,errorWritable=void 0,transforming=!1,chunkWrittenButNotYetTransformed=!1;this.writable=new WritableStream({start:function(error){errorWritable=error},write:function(chunk){writeChunk=chunk,chunkWrittenButNotYetTransformed=!0;var p=new Promise(function(resolve){return writeDone=resolve});return maybeDoTransform(),p},close:function(){try{transformer.flush(enqueueInReadable,closeReadable)}catch(e){errorWritable(e),errorReadable(e)}}},transformer.writableStrategy);var enqueueInReadable=void 0,closeReadable=void 0,errorReadable=void 0;this.readable=new ReadableStream({start:function(c){enqueueInReadable=c.enqueue.bind(c),closeReadable=c.close.bind(c),errorReadable=c.error.bind(c)},pull:function(){chunkWrittenButNotYetTransformed===!0&&maybeDoTransform()}},transformer.readableStrategy)}},{\"./readable-stream.js\":11,\"./writable-stream.js\":14}],13:[function(require,module,exports){\"use strict\";var assert=require(\"assert\");exports.rethrowAssertionErrorRejection=function(e){e&&e.constructor===assert.AssertionError&&setTimeout(function(){throw e},0)}},{assert:2}],14:[function(require,module,exports){\"use strict\";function _classCallCheck(instance,Constructor){if(!(instance instanceof Constructor))throw new TypeError(\"Cannot call a class as a function\")}function closure_WritableStreamErrorFunction(){var f=function f(e){return ErrorWritableStream(f._stream,e)};return f}function CallOrScheduleWritableStreamAdvanceQueue(stream){return stream._started===!1?void stream._startedPromise.then(function(){WritableStreamAdvanceQueue(stream)}).catch(rethrowAssertionErrorRejection):stream._started===!0?WritableStreamAdvanceQueue(stream):void 0}function CloseWritableStream(stream){assert(\"closing\"===stream._state,\"stream must be in closing state while calling CloseWritableStream\");var sinkClosePromise=PromiseInvokeOrNoop(stream._underlyingSink,\"close\");sinkClosePromise.then(function(){\"errored\"!==stream._state&&(assert(\"closing\"===stream._state),stream._closedPromise_resolve(void 0),stream._closedPromise_resolve=void 0,stream._closedPromise_reject=void 0,stream._state=\"closed\")},function(r){return ErrorWritableStream(stream,r)}).catch(rethrowAssertionErrorRejection)}function ErrorWritableStream(stream,e){if(\"closed\"!==stream._state&&\"errored\"!==stream._state){for(;stream._queue.length>0;){var writeRecord=DequeueValue(stream._queue);\"close\"!==writeRecord&&writeRecord._reject(e)}stream._storedError=e,\"waiting\"===stream._state&&stream._readyPromise_resolve(void 0),stream._closedPromise_reject(e),stream._closedPromise_resolve=void 0,stream._closedPromise_reject=void 0,stream._state=\"errored\"}}function IsWritableStream(x){return!!typeIsObject(x)&&!!Object.prototype.hasOwnProperty.call(x,\"_underlyingSink\")}function SyncWritableStreamStateWithQueue(stream){if(\"closing\"!==stream._state){assert(\"writable\"===stream._state||\"waiting\"===stream._state,\"stream must be in a writable or waiting state while calling SyncWritableStreamStateWithQueue\");var queueSize=GetTotalQueueSize(stream._queue),shouldApplyBackpressure=queueSize>stream._strategyHWM;shouldApplyBackpressure===!0&&\"writable\"===stream._state&&(stream._state=\"waiting\",stream._readyPromise=new Promise(function(resolve,reject){stream._readyPromise_resolve=resolve})),shouldApplyBackpressure===!1&&\"waiting\"===stream._state&&(stream._state=\"writable\",stream._readyPromise_resolve(void 0))}}function WritableStreamAdvanceQueue(stream){if(0!==stream._queue.length&&stream._writing!==!0){var writeRecord=PeekQueueValue(stream._queue);return\"close\"===writeRecord?(assert(\"closing\"===stream._state,\"can't process final write record unless already closing\"),DequeueValue(stream._queue),assert(0===stream._queue.length,\"queue must be empty once the final write record is dequeued\"),CloseWritableStream(stream)):(stream._writing=!0,void PromiseInvokeOrNoop(stream._underlyingSink,\"write\",[writeRecord.chunk]).then(function(){\"errored\"!==stream._state&&(stream._writing=!1,writeRecord._resolve(void 0),DequeueValue(stream._queue),SyncWritableStreamStateWithQueue(stream),WritableStreamAdvanceQueue(stream))},function(r){return ErrorWritableStream(stream,r)}).catch(rethrowAssertionErrorRejection))}}var _createClass=function(){function defineProperties(target,props){for(var i=0;i { if (res.status === 404) { @@ -143,21 +144,25 @@ class SemanticChessGame { } else if (quad) { store.addQuad(quad); } else { - const firstHalfMoves = store.getQuads(namedNode(gameUrl), namedNode(chessOnto + 'hasFirstHalfMove'), null).map(a => a.object); - - if (firstHalfMoves.length > 0) { - console.log(firstHalfMoves); - } - const source = { match: function(s, p, o, g) { return require('streamify-array')(store.getQuads(s, p, o, g)); } }; + const myEngine = newEngine(); + + myEngine.query(`SELECT * { <${gameUrl}> ?p ?firstMove. + } LIMIT 100`, + { sources: [ { type: 'rdfjsSource', value: source } ] }) + .then(function (result) { + result.bindingsStream.on('data', function (data) { + // Each data object contains a mapping from variables to RDFJS terms. + console.log(data); + }); + }); // Create our engine, and query it. // If you intend to query multiple times, be sure to cache your engine for optimal performance. - const myEngine = newEngine(); myEngine.query(`SELECT * { ?agentRole <${rdf}type> ?playerRole; <${chessOnto}performedBy> <${userWebId}> } LIMIT 100`, { sources: [ { type: 'rdfjsSource', value: source } ] }) diff --git a/package-lock.json b/package-lock.json index 27ab191..3e17ac0 100644 --- a/package-lock.json +++ b/package-lock.json @@ -2576,12 +2576,14 @@ "balanced-match": { "version": "1.0.0", "bundled": true, - "dev": true + "dev": true, + "optional": true }, "brace-expansion": { "version": "1.1.11", "bundled": true, "dev": true, + "optional": true, "requires": { "balanced-match": "^1.0.0", "concat-map": "0.0.1" @@ -2596,17 +2598,20 @@ "code-point-at": { "version": "1.1.0", "bundled": true, - "dev": true + "dev": true, + "optional": true }, "concat-map": { "version": "0.0.1", "bundled": true, - "dev": true + "dev": true, + "optional": true }, "console-control-strings": { "version": "1.1.0", "bundled": true, - "dev": true + "dev": true, + "optional": true }, "core-util-is": { "version": "1.0.2", @@ -2723,7 +2728,8 @@ "inherits": { "version": "2.0.3", "bundled": true, - "dev": true + "dev": true, + "optional": true }, "ini": { "version": "1.3.5", @@ -2735,6 +2741,7 @@ "version": "1.0.0", "bundled": true, "dev": true, + "optional": true, "requires": { "number-is-nan": "^1.0.0" } @@ -2749,6 +2756,7 @@ "version": "3.0.4", "bundled": true, "dev": true, + "optional": true, "requires": { "brace-expansion": "^1.1.7" } @@ -2756,12 +2764,14 @@ "minimist": { "version": "0.0.8", "bundled": true, - "dev": true + "dev": true, + "optional": true }, "minipass": { "version": "2.2.4", "bundled": true, "dev": true, + "optional": true, "requires": { "safe-buffer": "^5.1.1", "yallist": "^3.0.0" @@ -2780,6 +2790,7 @@ "version": "0.5.1", "bundled": true, "dev": true, + "optional": true, "requires": { "minimist": "0.0.8" } @@ -2860,7 +2871,8 @@ "number-is-nan": { "version": "1.0.1", "bundled": true, - "dev": true + "dev": true, + "optional": true }, "object-assign": { "version": "4.1.1", @@ -2872,6 +2884,7 @@ "version": "1.4.0", "bundled": true, "dev": true, + "optional": true, "requires": { "wrappy": "1" } @@ -2993,6 +3006,7 @@ "version": "1.0.2", "bundled": true, "dev": true, + "optional": true, "requires": { "code-point-at": "^1.0.0", "is-fullwidth-code-point": "^1.0.0", @@ -4168,8 +4182,13 @@ "resolved": "https://registry.npmjs.org/node-web-streams/-/node-web-streams-0.2.2.tgz", "integrity": "sha1-CH52u+t+jcVmhrJdtOYMX/nbCR8=", "requires": { - "is-stream": "^1.1.0", - "web-streams-polyfill": "git://github.com/gwicke/web-streams-polyfill.git#42c488428adea1dc0c0245014e4896ad456b1ded" + "is-stream": "^1.1.0" + }, + "dependencies": { + "web-streams-polyfill": { + "version": "git://github.com/gwicke/web-streams-polyfill.git#42c488428adea1dc0c0245014e4896ad456b1ded", + "from": "git://github.com/gwicke/web-streams-polyfill.git#42c488428adea1dc0c0245014e4896ad456b1ded" + } } }, "normalize-path": { @@ -5672,10 +5691,6 @@ "neo-async": "^2.5.0" } }, - "web-streams-polyfill": { - "version": "git://github.com/gwicke/web-streams-polyfill.git#42c488428adea1dc0c0245014e4896ad456b1ded", - "from": "git://github.com/gwicke/web-streams-polyfill.git#spec_performance_improvements" - }, "webidl-conversions": { "version": "4.0.2", "resolved": "https://registry.npmjs.org/webidl-conversions/-/webidl-conversions-4.0.2.tgz",