mirror of
https://github.com/denoland/deno.git
synced 2024-12-12 18:42:18 -05:00
34 lines
800 B
TypeScript
34 lines
800 B
TypeScript
// Copyright 2018-2020 the Deno authors. All rights reserved. MIT license.
|
|
|
|
export function fromStreamWriter(
|
|
streamWriter: WritableStreamDefaultWriter<Uint8Array>
|
|
): Deno.Writer {
|
|
return {
|
|
async write(p: Uint8Array): Promise<number> {
|
|
await streamWriter.ready;
|
|
await streamWriter.write(p);
|
|
return p.length;
|
|
},
|
|
};
|
|
}
|
|
|
|
export function fromStreamReader(
|
|
streamReader: ReadableStreamDefaultReader<Uint8Array>
|
|
): Deno.Reader {
|
|
const buffer = new Deno.Buffer();
|
|
|
|
return {
|
|
async read(p: Uint8Array): Promise<number | null> {
|
|
if (buffer.empty()) {
|
|
const res = await streamReader.read();
|
|
if (res.done) {
|
|
return null; // EOF
|
|
}
|
|
|
|
await Deno.writeAll(buffer, res.value);
|
|
}
|
|
|
|
return buffer.read(p);
|
|
},
|
|
};
|
|
}
|