fix(incoming): 解决存量缓冲内容读取失败问题 (#573)

* fix(incoming): 解决存量缓冲内容读取失败问题

* fix(index): 测试完需要清理hack逻辑

Author: RobinzZH

lib/__test__/index.test.ts

@@ -26,6 +26,7 @@ beforeAll(() => {
 
 afterAll(() => {
   server.close();
+  uninstallHacks();
 });
 
 describe("tsw index", () => {

lib/core/runtime/capture/__test__/incoming.test.ts

@@ -46,6 +46,7 @@ describe("capture response function test", () => {
       path: "/",
       method: "POST",
       headers: {
+        Connection: "Close",
         "Content-Type": "application/x-www-form-urlencoded",
         "Content-Length": Buffer.byteLength(data)
       }

lib/core/runtime/capture/incoming.ts

@@ -45,10 +45,17 @@ export const captureReadableStream = (
     info.bodyTooLarge = info.bodyLength > maxBodySize;
   };
 
-  let { head } = (stream as any).readableBuffer;
-  while (head) {
-    handler(head.data);
-    head = head.next;
+  const rb = (stream as any).readableBuffer;
+  let { head } = rb;
+  if (head !== undefined) {
+    while (head) {
+      handler(head.data);
+      head = head.next;
+    }
+  } else if (rb.forEach) {
+    rb.forEach((c) => {
+      handler(c);
+    });
   }
 
   (stream as any).push = (chunk: any, encoding?: string): boolean => {