fix(ext/node): worker_threads.receiveMessageOnPort doesn't panic

a.ts

@@ -0,0 +1,21 @@
+import workerThreads from "node:worker_threads";
+import { assertEquals } from "jsr:@std/assert";
+
+const { port1, port2 } = new workerThreads.MessageChannel();
+
+const message1 = { hello: "world" };
+const message2 = { foo: "bar" };
+
+assertEquals(workerThreads.receiveMessageOnPort(port2), undefined);
+port2.start();
+
+port1.postMessage(message1);
+port1.postMessage(message2);
+assertEquals(workerThreads.receiveMessageOnPort(port2), {
+  message: message1,
+});
+assertEquals(workerThreads.receiveMessageOnPort(port2), {
+  message: message2,
+});
+port1.close();
+port2.close();

ext/web/message_port.rs

@@ -15,6 +15,7 @@ use deno_core::OpState;
 use deno_core::RcRef;
 use deno_core::Resource;
 use deno_core::ResourceId;
+use futures::future::poll_fn;
 use serde::Deserialize;
 use serde::Serialize;
 use tokio::sync::mpsc::error::TryRecvError;
@@ -52,16 +53,19 @@ impl MessagePort {
     Ok(())
   }
 
-  #[allow(clippy::await_holding_refcell_ref)] // TODO(ry) remove!
   pub async fn recv(
     &self,
     state: Rc<RefCell<OpState>>,
   ) -> Result<Option<JsMessageData>, AnyError> {
-    let mut rx = self
-      .rx
-      .try_borrow_mut()
-      .map_err(|_| type_error("Port receiver is already borrowed"))?;
-    if let Some((data, transferables)) = rx.recv().await {
+    let rx = &self.rx;
+
+    let maybe_data = poll_fn(|cx| {
+      let mut rx = rx.borrow_mut();
+      rx.poll_recv(cx)
+    })
+    .await;
+
+    if let Some((data, transferables)) = maybe_data {
       let js_transferables =
         serialize_transferables(&mut state.borrow_mut(), transferables);
       return Ok(Some(JsMessageData {

foo.js

@@ -0,0 +1,9 @@
+import Tinypool from "npm:tinypool";
+
+const pool = new Tinypool({
+  filename: new URL("./worker.mjs", import.meta.url).href,
+});
+const result = await pool.run({ a: 4, b: 6 });
+console.log(result); // Prints 10
+
+await pool.destroy();

worker.mjs

@@ -0,0 +1 @@
+export default ({ a, b }) =>  a + b;