wip

denoland · Sep 11, 2024 · abda518 · abda518
1 parent 0ecd93a
commit abda518
Show file tree

Hide file tree

Showing 3 changed files with 1,175 additions and 1,174 deletions.
diff --git a/ext/node/polyfills/_stream.mjs b/ext/node/polyfills/_stream.mjs
@@ -3193,6 +3193,7 @@ var require_readable = __commonJS({
       return ret;
     }
     function endReadable(stream) {
+      console.trace("endReadable invoked");
       const state = stream._readableState;
       debug("endReadable", state.endEmitted);
       if (!state.endEmitted) {

diff --git a/ext/node/polyfills/http.ts b/ext/node/polyfills/http.ts
@@ -589,7 +589,6 @@ class ClientRequest extends OutgoingMessage {
   }
 
   _writeHeader() {
-    console.trace("_writeHeader");
     const url = this._createUrlStrFromOptions();
 
     const headers = [];
@@ -767,7 +766,6 @@ class ClientRequest extends OutgoingMessage {
     nextTick(() => {
       this.socket = socket;
       this.emit("socket", socket);
-      console.trace("onSocket invoked", socket);
     });
   }
 
@@ -1096,6 +1094,7 @@ export class IncomingMessageForClient extends NodeReadable {
   }
 
   _read(_n) {
+    console.trace("_read invoked");
     if (!this._consuming) {
       this._readableState.readingMore = false;
       this._consuming = true;
@@ -1104,6 +1103,7 @@ export class IncomingMessageForClient extends NodeReadable {
     const buf = new Uint8Array(16 * 1024);
 
     core.read(this._bodyRid, buf).then((bytesRead) => {
+      console.log("bytes read:", bytesRead);
       if (bytesRead === 0) {
         this.push(null);
       } else {