fromAnyIterable.js•749 B
function c(n) {
const t = a(n);
return new ReadableStream(
{
async pull(e) {
const { value: r, done: o } = await t.next();
o ? e.close() : e.enqueue(r);
},
async cancel(e) {
if (typeof t.return == "function" && typeof await t.return(e) != "object")
throw new TypeError("return() fulfills with a non-object.");
return e;
}
},
new CountQueuingStrategy({
highWaterMark: 0
})
);
}
function a(n) {
let t = n[Symbol.asyncIterator]?.bind(n);
if (t === void 0) {
const r = n[Symbol.iterator](), o = {
[Symbol.iterator]: () => r
};
t = async function* () {
return yield* o;
};
}
return t();
}
export {
c as fromAnyIterable
};