Server Stream is working as intended, able to pass configurations for…

… requests in metadata
firecomm · Aug 11, 2019 · cc6576b · cc6576b
1 parent ce0d844
commit cc6576b
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 4 deletions.
diff --git a/examples/firecomm/client.js b/examples/firecomm/client.js
@@ -91,16 +91,26 @@ const firstChat = {
 
 // const testServerStream = () => {
   // const serverStream = stub.serverStream(firstChat);
-  const serverStream = stub.serverStream();
+  const serverStream = stub.serverStream(
+    {
+      stream: 'server',
+      options: {
+        idempotentRequest: true,
+        cacheableRequest: true,
+        corked: true,
+        waitForReady: false,
+      }
+    }
+    );
   serverStream.write(firstChat);
   serverStream.on("data", data => {
-    console.log({data});
+    console.log(data);
   })
   serverStream.on("status", status => {
-    console.log({status});
+    console.log(status);
   })
   serverStream.on("metadata", metadata => {
-    console.log({metadata});
+    console.log(metadata);
   })
   .catch((err) => console.error(err));
 // };

diff --git a/examples/firecomm/methodHandlers.js b/examples/firecomm/methodHandlers.js
@@ -14,6 +14,7 @@ function unaryChat(call) {
 
 function serverStream(call) {
   // console.log(context);
+  call.set({server: 'streamed metadata'})
   let count = 0;
   setInterval(() => {
     count += 1;