Gecko [ gandhischool.edu.np ]

Name	Size	Permission
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-

Code Editor : concatenate.js

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 };

${this.title}

Code Editor : concatenate.js