From b4e67ee767849d2283932212301d25a88bf197c4 Mon Sep 17 00:00:00 2001
From: Adrian Grassl <adrian.grassl@iota.org>
Date: Mon, 4 Jul 2022 10:45:43 +0200
Subject: [PATCH 1/2] Fix dependabot alert

---
 examples/nodejs/package-lock.json | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/examples/nodejs/package-lock.json b/examples/nodejs/package-lock.json
index efdbbd6..8973d06 100644
--- a/examples/nodejs/package-lock.json
+++ b/examples/nodejs/package-lock.json
@@ -625,9 +625,9 @@
       "integrity": "sha512-JLyh7xT1kizaEvcaXOQwOc2/Yhw6KZOvPf1S8401UyLk86CU79LN3vl7ztXGm/pZ+YjoyAJ4rxmHwbkBXJX+yw=="
     },
     "node_modules/protobufjs": {
-      "version": "6.11.2",
-      "resolved": "https://registry.npmjs.org/protobufjs/-/protobufjs-6.11.2.tgz",
-      "integrity": "sha512-4BQJoPooKJl2G9j3XftkIXjoC9C0Av2NOrWmbLWT1vH32GcSUHjM0Arra6UfTsVyfMAuFzaLucXn1sadxJydAw==",
+      "version": "6.11.3",
+      "resolved": "https://registry.npmjs.org/protobufjs/-/protobufjs-6.11.3.tgz",
+      "integrity": "sha512-xL96WDdCZYdU7Slin569tFX712BxsxslWwAfAhCYjQKGTq7dAU91Lomy6nLLhh/dyGhk/YH4TwTSRxTzhuHyZg==",
       "hasInstallScript": true,
       "dependencies": {
         "@protobufjs/aspromise": "^1.1.2",
@@ -1321,9 +1321,9 @@
       "integrity": "sha512-JLyh7xT1kizaEvcaXOQwOc2/Yhw6KZOvPf1S8401UyLk86CU79LN3vl7ztXGm/pZ+YjoyAJ4rxmHwbkBXJX+yw=="
     },
     "protobufjs": {
-      "version": "6.11.2",
-      "resolved": "https://registry.npmjs.org/protobufjs/-/protobufjs-6.11.2.tgz",
-      "integrity": "sha512-4BQJoPooKJl2G9j3XftkIXjoC9C0Av2NOrWmbLWT1vH32GcSUHjM0Arra6UfTsVyfMAuFzaLucXn1sadxJydAw==",
+      "version": "6.11.3",
+      "resolved": "https://registry.npmjs.org/protobufjs/-/protobufjs-6.11.3.tgz",
+      "integrity": "sha512-xL96WDdCZYdU7Slin569tFX712BxsxslWwAfAhCYjQKGTq7dAU91Lomy6nLLhh/dyGhk/YH4TwTSRxTzhuHyZg==",
       "requires": {
         "@protobufjs/aspromise": "^1.1.2",
         "@protobufjs/base64": "^1.1.2",

From 64b77bfe54dfdcda82447e3cd5778e08d30c3677 Mon Sep 17 00:00:00 2001
From: Adrian Grassl <adrian.grassl@iota.org>
Date: Mon, 4 Jul 2022 10:50:23 +0200
Subject: [PATCH 2/2] Add nodejs example for client stream

---
 examples/nodejs/client_stream.js | 40 ++++++++++++++++++++++++++++++++
 1 file changed, 40 insertions(+)
 create mode 100644 examples/nodejs/client_stream.js

diff --git a/examples/nodejs/client_stream.js b/examples/nodejs/client_stream.js
new file mode 100644
index 0000000..f6f948b
--- /dev/null
+++ b/examples/nodejs/client_stream.js
@@ -0,0 +1,40 @@
+const grpc = require("@grpc/grpc-js");
+const protoLoader = require("@grpc/proto-loader");
+const PROTO_PATH = "../../proto/inx.proto";
+
+
+const INX_ADDRESS = "localhost:9029";
+
+
+const protoOptions = {
+    keepCase: true,
+    longs: String,
+    enums: String,
+    defaults: true,
+    oneofs: true,
+};
+
+
+// Load the `inx.proto` file
+const packageDefinition = protoLoader.loadSync(PROTO_PATH, protoOptions);
+const INX = grpc.loadPackageDefinition(packageDefinition).inx.INX;
+// Instantiate an INX client
+const client = new INX(
+    INX_ADDRESS,
+    grpc.credentials.createInsecure()
+);
+
+// Listen to the stream of latest milestones
+var call = client.ListenToLatestMilestones();
+call.on('data', function (answer) {
+    console.log(answer);
+});
+call.on('end', function () {
+    // The server has finished sending
+});
+call.on('error', function (error) {
+    // An error has occurred and the stream has been closed.
+});
+call.on('status', function (status) {
+    // process status
+});
\ No newline at end of file