Spaces:
Sleeping
Sleeping
File size: 3,662 Bytes
be5030f |
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 |
// 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.
import { toUint8Array } from '../../util/buffer';
import { isIterable, isAsyncIterable } from '../../util/compat';
/** @ignore */
export function toDOMStream(source, options) {
if (isAsyncIterable(source)) {
return asyncIterableAsReadableDOMStream(source, options);
}
if (isIterable(source)) {
return iterableAsReadableDOMStream(source, options);
}
/* istanbul ignore next */
throw new Error(`toDOMStream() must be called with an Iterable or AsyncIterable`);
}
/** @ignore */
function iterableAsReadableDOMStream(source, options) {
let it = null;
const bm = (options && options.type === 'bytes') || false;
const hwm = options && options.highWaterMark || (2 ** 24);
return new ReadableStream({
...options,
start(controller) { next(controller, it || (it = source[Symbol.iterator]())); },
pull(controller) { it ? (next(controller, it)) : controller.close(); },
cancel() { (it && (it.return && it.return()) || true) && (it = null); }
}, { 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 = 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 && options.type === 'bytes') || false;
const hwm = options && options.highWaterMark || (2 ** 24);
return new ReadableStream({
...options,
async start(controller) { await next(controller, it || (it = source[Symbol.asyncIterator]())); },
async pull(controller) { it ? (await next(controller, it)) : controller.close(); },
async cancel() { (it && (it.return && await it.return()) || true) && (it = null); },
}, { highWaterMark: bm ? hwm : undefined, ...options });
async function next(controller, it) {
let buf;
let r = null;
let size = controller.desiredSize || null;
while (!(r = await it.next(bm ? size : null)).done) {
if (ArrayBuffer.isView(r.value) && (buf = 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.mjs.map
|