[pinpoint-apm#182] Support gRPC stream flowable

[pinpoint-apm#177] Update minimum NodeJS version to Node@16

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

@@ -0,0 +1,53 @@
+/**
+ * Pinpoint Node.js Agent
+ * Copyright 2021-present NAVER Corp.
+ * Apache License v2.0
+ */
+
+'use strict'
+
+const { Readable } = require('node:stream')
+
+class BoundedBufferReadableStream {
+    constructor(constructorOptions) {
+        this.buffer = []
+        this.stopped = false
+
+        const options = constructorOptions || {}
+        this.readable = new Readable(Object.assign({
+            read() {
+                this.stopped = false
+                this.readStart()
+            }
+        }, options))
+    }
+
+    push(data) {
+        if (!data) {
+            return
+        }
+
+        this.buffer.push(data)
+        this.readStart()
+    }
+
+    end() {
+        this.readable.end()
+    }
+
+    readStart() {
+        if (this.stopped) {
+            return
+        }
+
+        const length = this.buffer.length
+        for (let index = 0; index < length; index++) {
+            if (this.readable.push(this.buffer.shift())) {
+                this.stopped = true
+                return
+            }
+        }
+    }
+}
+
+module.exports = BoundedBufferReadableStream

package.json

@@ -1,6 +1,6 @@
 {
   "name": "pinpoint-node-agent",
-  "version": "0.9.0-next.4",
+  "version": "1.0.0-next.1",
   "main": "index.js",
   "types": "index.d.ts",
   "type": "commonjs",
@@ -23,7 +23,7 @@
   },
   "homepage": "https://github.com/pinpoint-apm/pinpoint-node-agent",
   "engines": {
-    "node": ">=14.0"
+    "node": ">=16.0"
   },
   "keywords": [
     "pinpoint",

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

@@ -0,0 +1,8 @@
+/**
+ * Pinpoint Node.js Agent
+ * Copyright 2020-present NAVER Corp.
+ * Apache License v2.0
+ */
+
+const test = require('tape')
+