[pinpoint-apm#183] Fix axios node@20 an Error on Test

.github/workflows/main.yml

@@ -16,6 +16,7 @@ jobs:
         node_version:
           - 16
           - 18
+          - 20
 
     name: Node ${{ matrix.node_version }} on ubuntu-latest
     steps:

lib/client/bounded-buffer-readable-stream.js

@@ -37,12 +37,7 @@ class BoundedBufferReadableStream {
         })
 
         readableStream.on('close', () => {
-            if (!this.writableFactory) {
-                return
-            }
-
-            this.readableStream = this.makeReadableSteam()
-            this._pipe()
+            this.needsNewReadableStream = true
         })
 
         return readableStream
@@ -63,6 +58,11 @@ class BoundedBufferReadableStream {
     }
 
     readStart() {
+        if (this.needsNewReadableStream) {
+            this.readableStream = this.makeReadableSteam()
+            this._pipe()
+        }
+
         this.readable = true
 
         const length = this.buffer.length

test/client/bounded-buffer-readable-stream.test.js

@@ -121,9 +121,9 @@ test('reconnect writable stream on piped readable stream', (t) => {
 
 test('If the Readable stream emits an error during processing, the writable destination is not closed automatically. If an error occurs, Close each streams, ', async (t) => {
     if (semver.satisfies(process.versions.node, '<17.0')) {
-        t.plan(16)
+        t.plan(15)
     } else {
-        t.plan(19)
+        t.plan(18)
     }
 
     const readable = new BoundedBufferReadableStream()
@@ -149,7 +149,7 @@ test('If the Readable stream emits an error during processing, the writable dest
         t.true(this.destroyed, 'destroyed property is true on close event of readable steam')
 
         // recovery readable steam
-        t.true(readable.readableStream.readable, 'readable property is true on close event of recovery readable steam after error')
+        // t.true(readable.readableStream.readable, 'readable property is true on close event of recovery readable steam after error')
     })
 
     t.equal(readable.buffer[0], 'test1', 'buffer[0] is test1')