1
0
Fork 0
mirror of https://github.com/denoland/deno.git synced 2025-01-05 13:59:01 -05:00

refactor(runtime/io): use primordials (#15906)

This commit is contained in:
Marcos Casagrande 2022-09-15 10:05:41 +02:00 committed by cjihrig
parent f911b58631
commit a253ec4e55
No known key found for this signature in database
GPG key ID: 7434390BDBE9B9C5

View file

@ -145,7 +145,7 @@
const buf = new Uint8Array(READ_PER_ITER);
const read = r.readSync(buf);
if (typeof read == "number") {
ArrayPrototypePush(buffers, buf.subarray(0, read));
ArrayPrototypePush(buffers, TypedArrayPrototypeSubarray(buf, 0, read));
} else {
break;
}
@ -177,7 +177,7 @@
while (cursor < size) {
const sliceEnd = MathMin(size + 1, cursor + READ_PER_ITER);
const slice = buf.subarray(cursor, sliceEnd);
const slice = TypedArrayPrototypeSubarray(buf, cursor, sliceEnd);
const read = r.readSync(slice);
if (typeof read == "number") {
cursor += read;
@ -191,7 +191,7 @@
// Read remaining and concat
return concatBuffers([buf, readAllSync(r)]);
} else { // cursor == size
return buf.subarray(0, cursor);
return TypedArrayPrototypeSubarray(buf, 0, cursor);
}
}
@ -202,7 +202,7 @@
while (cursor < size) {
signal?.throwIfAborted();
const sliceEnd = MathMin(size + 1, cursor + READ_PER_ITER);
const slice = buf.subarray(cursor, sliceEnd);
const slice = TypedArrayPrototypeSubarray(buf, cursor, sliceEnd);
const read = await r.read(slice);
if (typeof read == "number") {
cursor += read;
@ -217,7 +217,7 @@
// Read remaining and concat
return concatBuffers([buf, await readAllInner(r, options)]);
} else {
return buf.subarray(0, cursor);
return TypedArrayPrototypeSubarray(buf, 0, cursor);
}
}