fix starvation by adding pause to read/recv

Author: Guest0x0

src/pipe/moon.pkg.json

@@ -1,8 +1,8 @@
 {
   "import": [
     "moonbitlang/async/os_error",
-    "moonbitlang/async/internal/event_loop"
+    "moonbitlang/async/internal/event_loop",
+    "moonbitlang/async"
   ],
-  "test-import": [ "moonbitlang/async" ],
   "native-stub": [ "stub.c" ]
 }

src/pipe/pipe.mbt

@@ -137,6 +137,7 @@ pub async fn PipeRead::read(
     @event_loop.wait_fd_read(fd)
     read_ffi(fd, buf, offset, max_len)
   } else {
+    @async.pause()
     n_read
   }
   if n_read < 0 {

src/socket/moon.pkg.json

@@ -1,8 +1,8 @@
 {
   "import": [
     "moonbitlang/async/os_error",
-    "moonbitlang/async/internal/event_loop"
+    "moonbitlang/async/internal/event_loop",
+    "moonbitlang/async"
   ],
-  "test-import": [ "moonbitlang/async" ],
   "native-stub": [ "socket.c" ]
 }

src/socket/tcp.mbt

@@ -132,6 +132,7 @@ pub async fn TCP::recv(
     @event_loop.wait_fd_read(sock)
     recv_ffi(sock, buf, offset, max_len)
   } else {
+    @async.pause()
     n_read
   }
   if n_read < 0 {