Move web streams to dcore

test.js

@@ -0,0 +1,31 @@
+function iteratorToStream(iterator) {
+  return new ReadableStream({
+    async pull(controller) {
+      const { value, done } = await iterator.next();
+
+      if (value) {
+        controller.enqueue(value);
+      }
+      if (done) {
+        controller.close();
+      }
+    },
+  });
+}
+
+const iterator = (async function* () {
+  yield "Hello";
+  yield "world";
+})();
+
+const stream = iteratorToStream(iterator);
+
+const reader = stream.getReader();
+
+while (true) {
+  const { done, value } = await reader.read();
+  if (done) {
+    break;
+  }
+  console.log(value);
+}

testing/Cargo.toml

@@ -15,10 +15,12 @@ path = "./lib.rs"
 
 [dependencies]
 anyhow.workspace = true
+bytes.workspace = true
 deno_ast.workspace = true
 deno_core.workspace = true
 deno_core.features = ["unsafe_use_unprotected_platform", "snapshot_flags_eager_parse"]
 futures.workspace = true
+thiserror.workspace = true
 tokio.workspace = true
 url.workspace = true
 

testing/checkin/runner/extensions.rs

@@ -6,6 +6,7 @@ use crate::checkin::runner::ops_buffer;
 use crate::checkin::runner::ops_error;
 use crate::checkin::runner::ops_io;
 use crate::checkin::runner::ops_worker;
+use crate::checkin::runner::streams;
 use crate::checkin::runner::Output;
 use crate::checkin::runner::TestData;
 
@@ -49,6 +50,14 @@ deno_core::extension!(
     ops_worker::op_worker_parent,
     ops_worker::op_worker_await_close,
     ops_worker::op_worker_terminate,
+    streams::op_readable_stream_resource_allocate,
+    streams::op_readable_stream_resource_allocate_sized,
+    streams::op_readable_stream_resource_get_sink,
+    streams::op_readable_stream_resource_write_error,
+    streams::op_readable_stream_resource_write_buf,
+    streams::op_readable_stream_resource_write_sync,
+    streams::op_readable_stream_resource_close,
+    streams::op_readable_stream_resource_await_close,
   ],
   objects = [
     ops::DOMPoint,
@@ -61,8 +70,10 @@ deno_core::extension!(
     "checkin:async" = "async.ts",
     "checkin:console" = "console.ts",
     "checkin:object" = "object.ts",
+    "checkin:streams" = "streams.ts",
     "checkin:error" = "error.ts",
     "checkin:timers" = "timers.ts",
+    "checkin:webidl" = "webidl.ts",
     "checkin:worker" = "worker.ts",
     "checkin:throw" = "throw.ts",
   ],

testing/checkin/runner/mod.rs

@@ -36,6 +36,7 @@ mod ops_error;
 mod ops_io;
 mod ops_worker;
 pub mod snapshot;
+mod streams;
 #[cfg(test)]
 pub mod testing;
 mod ts_module_loader;