mirror of
https://github.com/denoland/deno.git
synced 2024-12-23 07:44:48 -05:00
72fe9bb470
This commit renames "deno_core::InternalModuleLoader" to "ExtModuleLoader" and changes the specifiers used by the modules loaded from this loader to "ext:". "internal:" scheme was really ambiguous and it's more characters than "ext:", which should result in slightly smaller snapshot size. Closes https://github.com/denoland/deno/issues/18020
78 lines
1.8 KiB
JavaScript
78 lines
1.8 KiB
JavaScript
// Copyright 2018-2023 the Deno authors. All rights reserved. MIT license.
|
|
// Copyright Joyent and Node contributors. All rights reserved. MIT license.
|
|
|
|
import { TextDecoder } from "ext:deno_web/08_text_encoding.js";
|
|
import { Buffer } from "ext:deno_node/buffer.ts";
|
|
|
|
/**
|
|
* @typedef {import('../_global.d.ts').ReadableStream
|
|
* } ReadableStream
|
|
* @typedef {import('../_stream.d.ts')} Readable
|
|
*/
|
|
|
|
/**
|
|
* @param {AsyncIterable|ReadableStream|Readable} stream
|
|
* @returns {Promise<Blob>}
|
|
*/
|
|
async function blob(stream) {
|
|
const chunks = [];
|
|
for await (const chunk of stream) {
|
|
chunks.push(chunk);
|
|
}
|
|
return new Blob(chunks);
|
|
}
|
|
|
|
/**
|
|
* @param {AsyncIterable|ReadableStream|Readable} stream
|
|
* @returns {Promise<ArrayBuffer>}
|
|
*/
|
|
async function arrayBuffer(stream) {
|
|
const ret = await blob(stream);
|
|
return ret.arrayBuffer();
|
|
}
|
|
|
|
/**
|
|
* @param {AsyncIterable|ReadableStream|Readable} stream
|
|
* @returns {Promise<Buffer>}
|
|
*/
|
|
async function buffer(stream) {
|
|
return Buffer.from(await arrayBuffer(stream));
|
|
}
|
|
|
|
/**
|
|
* @param {AsyncIterable|ReadableStream|Readable} stream
|
|
* @returns {Promise<string>}
|
|
*/
|
|
async function text(stream) {
|
|
const dec = new TextDecoder();
|
|
let str = "";
|
|
for await (const chunk of stream) {
|
|
if (typeof chunk === "string") {
|
|
str += chunk;
|
|
} else {
|
|
str += dec.decode(chunk, { stream: true });
|
|
}
|
|
}
|
|
// Flush the streaming TextDecoder so that any pending
|
|
// incomplete multibyte characters are handled.
|
|
str += dec.decode(undefined, { stream: false });
|
|
return str;
|
|
}
|
|
|
|
/**
|
|
* @param {AsyncIterable|ReadableStream|Readable} stream
|
|
* @returns {Promise<any>}
|
|
*/
|
|
async function json(stream) {
|
|
const str = await text(stream);
|
|
return JSON.parse(str);
|
|
}
|
|
|
|
export default {
|
|
arrayBuffer,
|
|
blob,
|
|
buffer,
|
|
json,
|
|
text,
|
|
};
|
|
export { arrayBuffer, blob, buffer, json, text };
|