@@ -1253,7 +1253,7 @@ function invokeOnerror(fn, error) {
 }
 
 function validateBody(body) {
-  if (body === undefined) return body;
+  if (body === undefined || body === null) return body;
   // ArrayBuffers, SharedArrayBuffers, and ArrayBufferViews are passed
   // through to the C++ layer which copies the bytes into its own
   // BackingStore. Callers can therefore safely reuse or mutate their
@@ -1290,6 +1290,7 @@ function validateBody(body) {
     'ArrayBufferView',
     'Blob',
     'FileHandle',
+    'null',
   ], body);
 }
 
 
@@ -290,11 +290,14 @@ std::unique_ptr<DataQueue::Entry> CreateEntryFromBuffer(
 
 Maybe<std::shared_ptr<DataQueue>> Stream::GetDataQueueFromSource(
     Environment* env, Local<Value> value) {
-  DCHECK_IMPLIES(!value->IsUndefined(), value->IsObject());
+  DCHECK(value->IsUndefined() || value->IsNull() || value->IsObject());
   std::vector<std::unique_ptr<DataQueue::Entry>> entries;
   if (value->IsUndefined()) {
     // Return an empty DataQueue.
     return Just(std::shared_ptr<DataQueue>());
+  } else if (value->IsNull()) {
+    // Return an empty, completed data source.
+    return Just(DataQueue::CreateIdempotent(std::move(entries)));
   } else if (value->IsArrayBuffer()) {
     auto buffer = value.As<ArrayBuffer>();
     auto length = buffer->ByteLength();
 
@@ -15,27 +15,57 @@ if (!hasQuic) {
 const { listen, connect } = await import('../common/quic.mjs');
 const { bytes } = await import('stream/iter');
 
-const serverDone = Promise.withResolvers();
-
-const serverEndpoint = await listen(mustCall((serverSession) => {
-  serverSession.onstream = mustCall(async (stream) => {
-    const received = await bytes(stream);
-    assert.strictEqual(received.byteLength, 0);
-    stream.writer.endSync();
-    await stream.closed;
-    serverSession.close();
-    serverDone.resolve();
-  });
-}));
-
-const clientSession = await connect(serverEndpoint.address);
-await clientSession.opened;
-
-const stream = await clientSession.createBidirectionalStream();
-stream.setBody(null);
-
-await dump(stream);
-
-await Promise.all([stream.closed, serverDone.promise]);
-await clientSession.close();
-await serverEndpoint.close();
+{
+  const serverDone = Promise.withResolvers();
+
+  const serverEndpoint = await listen(mustCall((serverSession) => {
+    serverSession.onstream = mustCall(async (stream) => {
+      const received = await bytes(stream);
+      assert.strictEqual(received.byteLength, 0);
+      stream.writer.endSync();
+      await stream.closed;
+      serverSession.close();
+      serverDone.resolve();
+    });
+  }));
+
+  const clientSession = await connect(serverEndpoint.address);
+  await clientSession.opened;
+
+  const stream = await clientSession.createBidirectionalStream();
+  stream.setBody(null);
+
+  await dump(stream);
+
+  await Promise.all([stream.closed, serverDone.promise]);
+  await clientSession.close();
+  await serverEndpoint.close();
+}
+
+// Stream via createBidirectionalStream({ body: null }).
+{
+  const serverDone = Promise.withResolvers();
+
+  const serverEndpoint = await listen(mustCall((serverSession) => {
+    serverSession.onstream = mustCall(async (stream) => {
+      const received = await bytes(stream);
+      assert.strictEqual(received.byteLength, 0);
+      stream.writer.endSync();
+      await stream.closed;
+      serverSession.close();
+      serverDone.resolve();
+    });
+  }));
+
+  const clientSession = await connect(serverEndpoint.address);
+  await clientSession.opened;
+
+  const stream =
+    await clientSession.createBidirectionalStream({ body: null });
+
+  await dump(stream);
+
+  await Promise.all([stream.closed, serverDone.promise]);
+  await clientSession.close();
+  await serverEndpoint.close();
+}
Original file line number	Diff line number	Diff line change
`@@ -1253,7 +1253,7 @@ function invokeOnerror(fn, error) {`
`1253`	`1253`	`}`
`1254`	`1254`
`1255`	`1255`	`function validateBody(body) {`
`1256`		`- if (body === undefined) return body;`
	`1256`	`+ if (body === undefined \|\| body === null) return body;`
`1257`	`1257`	`// ArrayBuffers, SharedArrayBuffers, and ArrayBufferViews are passed`
`1258`	`1258`	`// through to the C++ layer which copies the bytes into its own`
`1259`	`1259`	`// BackingStore. Callers can therefore safely reuse or mutate their`
`@@ -1290,6 +1290,7 @@ function validateBody(body) {`
`1290`	`1290`	`'ArrayBufferView',`
`1291`	`1291`	`'Blob',`
`1292`	`1292`	`'FileHandle',`
	`1293`	`+ 'null',`
`1293`	`1294`	`], body);`
`1294`	`1295`	`}`
`1295`	`1296`