Spaces:
Running
Running
File size: 4,556 Bytes
78c921d |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 |
"use strict";
// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
// to you under the Apache License, Version 2.0 (the
// "License"); you may not use this file except in compliance
// with the License. You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing,
// software distributed under the License is distributed on an
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
// KIND, either express or implied. See the License for the
// specific language governing permissions and limitations
// under the License.
Object.defineProperty(exports, "__esModule", { value: true });
exports.toDOMStream = void 0;
const tslib_1 = require("tslib");
const buffer_js_1 = require("../../util/buffer.js");
const compat_js_1 = require("../../util/compat.js");
/** @ignore */
function toDOMStream(source, options) {
if ((0, compat_js_1.isAsyncIterable)(source)) {
return asyncIterableAsReadableDOMStream(source, options);
}
if ((0, compat_js_1.isIterable)(source)) {
return iterableAsReadableDOMStream(source, options);
}
/* istanbul ignore next */
throw new Error(`toDOMStream() must be called with an Iterable or AsyncIterable`);
}
exports.toDOMStream = toDOMStream;
/** @ignore */
function iterableAsReadableDOMStream(source, options) {
let it = null;
const bm = ((options === null || options === void 0 ? void 0 : options.type) === 'bytes') || false;
const hwm = (options === null || options === void 0 ? void 0 : options.highWaterMark) || (Math.pow(2, 24));
return new ReadableStream(Object.assign(Object.assign({}, options), { start(controller) { next(controller, it || (it = source[Symbol.iterator]())); },
pull(controller) { it ? (next(controller, it)) : controller.close(); },
cancel() { ((it === null || it === void 0 ? void 0 : it.return) && it.return() || true) && (it = null); } }), Object.assign({ highWaterMark: bm ? hwm : undefined }, options));
function next(controller, it) {
let buf;
let r = null;
let size = controller.desiredSize || null;
while (!(r = it.next(bm ? size : null)).done) {
if (ArrayBuffer.isView(r.value) && (buf = (0, buffer_js_1.toUint8Array)(r.value))) {
size != null && bm && (size = size - buf.byteLength + 1);
r.value = buf;
}
controller.enqueue(r.value);
if (size != null && --size <= 0) {
return;
}
}
controller.close();
}
}
/** @ignore */
function asyncIterableAsReadableDOMStream(source, options) {
let it = null;
const bm = ((options === null || options === void 0 ? void 0 : options.type) === 'bytes') || false;
const hwm = (options === null || options === void 0 ? void 0 : options.highWaterMark) || (Math.pow(2, 24));
return new ReadableStream(Object.assign(Object.assign({}, options), { start(controller) {
return tslib_1.__awaiter(this, void 0, void 0, function* () { yield next(controller, it || (it = source[Symbol.asyncIterator]())); });
},
pull(controller) {
return tslib_1.__awaiter(this, void 0, void 0, function* () { it ? (yield next(controller, it)) : controller.close(); });
},
cancel() {
return tslib_1.__awaiter(this, void 0, void 0, function* () { ((it === null || it === void 0 ? void 0 : it.return) && (yield it.return()) || true) && (it = null); });
} }), Object.assign({ highWaterMark: bm ? hwm : undefined }, options));
function next(controller, it) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
let buf;
let r = null;
let size = controller.desiredSize || null;
while (!(r = yield it.next(bm ? size : null)).done) {
if (ArrayBuffer.isView(r.value) && (buf = (0, buffer_js_1.toUint8Array)(r.value))) {
size != null && bm && (size = size - buf.byteLength + 1);
r.value = buf;
}
controller.enqueue(r.value);
if (size != null && --size <= 0) {
return;
}
}
controller.close();
});
}
}
//# sourceMappingURL=iterable.js.map
|