From 95c191b28e3eeaec6324eaa60aef563deb8e0682 Mon Sep 17 00:00:00 2001
From: snwy <snwy@snwy.me>
Date: Mon, 11 Nov 2024 15:26:17 -0800
Subject: [PATCH] revert revert revert

---
 src/js/node/http.ts  | 12 ++++++++----
 src/js/node/http2.ts | 16 ++++++++++------
 2 files changed, 18 insertions(+), 10 deletions(-)

diff --git a/src/js/node/http.ts b/src/js/node/http.ts
index 30357ab69c..95fd0f25f0 100644
--- a/src/js/node/http.ts
+++ b/src/js/node/http.ts
@@ -1516,21 +1516,25 @@ class ClientRequest extends OutgoingMessage {
   _write(chunk, encoding, callback) {
     if (!this.#bodyChunks) {
       this.#bodyChunks = [chunk];
-      process.nextTick(callback);
+      // process.nextTick(callback);
+      callback();
       return;
     }
     this.#bodyChunks.push(chunk);
-    process.nextTick(callback);
+    // process.nextTick(callback);
+    callback();
   }
 
   _writev(chunks, callback) {
     if (!this.#bodyChunks) {
       this.#bodyChunks = chunks;
-      process.nextTick(callback);
+      // process.nextTick(callback);
+      callback();
       return;
     }
     this.#bodyChunks.push(...chunks);
-    process.nextTick(callback);
+    // process.nextTick(callback);
+    callback();
   }
 
   _destroy(err, callback) {
diff --git a/src/js/node/http2.ts b/src/js/node/http2.ts
index c60504d552..1943b6c160 100644
--- a/src/js/node/http2.ts
+++ b/src/js/node/http2.ts
@@ -1827,15 +1827,17 @@ class Http2Stream extends Duplex {
           chunk,
           undefined,
           (this[bunHTTP2StreamStatus] & StreamState.EndedCalled) !== 0,
-          function () {
+          /* function () {
             process.nextTick(this, ...arguments);
-          }.bind(callback),
+          }.bind(callback), */
+          callback,
         );
         return;
       }
     }
     if (typeof callback == "function") {
-      process.nextTick(callback);
+      // process.nextTick(callback);
+      callback();
     }
   }
   _write(chunk, encoding, callback) {
@@ -1848,15 +1850,17 @@ class Http2Stream extends Duplex {
           chunk,
           encoding,
           (this[bunHTTP2StreamStatus] & StreamState.EndedCalled) !== 0,
-          function () {
+          /* function () {
             process.nextTick(this, ...arguments);
-          }.bind(callback),
+          }.bind(callback), */
+          callback,
         );
         return;
       }
     }
 
-    typeof callback === "function" && process.nextTick(callback);
+    typeof callback === "function" && callback();
+    // process.nextTick(callback);
   }
 }
 class ClientHttp2Stream extends Http2Stream {