nodejs
diff --git a/‎doc/api/worker_threads.md‎
Lines changed: 5 additions & 1 deletion b/‎doc/api/worker_threads.md‎
Lines changed: 5 additions & 1 deletion
diff --git a/‎lib/internal/worker/io.js‎
Lines changed: 1 addition & 1 deletion b/‎lib/internal/worker/io.js‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎test/parallel/test-worker-broadcastchannel.js‎
Lines changed: 11 additions & 0 deletions b/‎test/parallel/test-worker-broadcastchannel.js‎
Lines changed: 11 additions & 0 deletions
@@ -179,9 +179,13 @@ if (isMainThread) {
 ## `worker.receiveMessageOnPort(port)`
 <!-- YAML
 added: v12.3.0
+changes:
+  - version: REPLACEME
+    pr-url: https://github.com/nodejs/node/pull/37535
+    description: The port argument can also refer to a `BroadcastChannel` now.
 -->
 
-* `port` {MessagePort}
+* `port` {MessagePort|BroadcastChannel}
 
 * Returns: {Object|undefined}
 
 
@@ -333,7 +333,7 @@ function createWorkerStdio() {
 }
 
 function receiveMessageOnPort(port) {
-  const message = receiveMessageOnPort_(port);
+  const message = receiveMessageOnPort_(port?.[kHandle] ?? port);
   if (message === noMessageSymbol) return undefined;
   return { message };
 }
 
@@ -4,6 +4,7 @@ const common = require('../common');
 const {
   BroadcastChannel,
   Worker,
+  receiveMessageOnPort
 } = require('worker_threads');
 const assert = require('assert');
 
@@ -140,3 +141,13 @@ assert.throws(() => new BroadcastChannel(), {
     message: /BroadcastChannel is closed/
   });
 }
+
+{
+  const bc1 = new BroadcastChannel('channel4');
+  const bc2 = new BroadcastChannel('channel4');
+  bc1.postMessage('some data');
+  assert.strictEqual(receiveMessageOnPort(bc2).message, 'some data');
+  assert.strictEqual(receiveMessageOnPort(bc2), undefined);
+  bc1.close();
+  bc2.close();
+}
Original file line number	Diff line number	Diff line change
@@ -333,7 +333,7 @@ function createWorkerStdio() {
333	333	}
334	334
335	335	function receiveMessageOnPort(port) {
336		- const message = receiveMessageOnPort_(port);
	336	+ const message = receiveMessageOnPort_(port?.[kHandle] ?? port);
337	337	if (message === noMessageSymbol) return undefined;
338	338	return { message };
339	339	}