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

denoland · Sep 15, 2022 · 606a6d7 · 606a6d7
1 parent 1de17fa
commit 606a6d7
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/runtime/js/12_io.js b/runtime/js/12_io.js
@@ -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);
     }
   }