idempotent requests, cacheable requests, corked requests, all possible

firecomm · Aug 10, 2019 · d3c2692 · d3c2692
1 parent bcfd08f
commit d3c2692
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 3 deletions.
diff --git a/examples/firecomm/client.js b/examples/firecomm/client.js
@@ -70,7 +70,9 @@ const firstChat = {
 
 // testClientStream();
 
-const newClient = stub.clientStream()
+const newClient = stub.clientStream(
+  {hello: 'world yo', 
+  options: {idempotentRequest: true}})
   .send({message: 'yolo'})
   .send(firstChat)
   .on((data) => console.log({ data }))

diff --git a/examples/firecomm/methodHandlers.js b/examples/firecomm/methodHandlers.js
@@ -25,6 +25,7 @@ function clientStream(call) {
   // console.log(context.__proto__);
   // console.log('serverStream context: ', context);
   // console.log(context.metadata, context.metaData);
+  console.log(call.head);
   call.set(
     {please: 'work', dear: 'dog'}
     )

diff --git a/lib/clientCalls/clientStreamCall.js b/lib/clientCalls/clientStreamCall.js
@@ -9,14 +9,18 @@ module.exports = function clientStreamCall(that, methodName, first, second) {
     if (Array.isArray(first)) {
       interceptors = { interceptors: first };
     } else {
-      metadata = generateMeta(first);
+      const {options} = first;
+      delete first.options;
+      metadata = generateMeta(first, options);
     }
   }
   if (typeof second === "object") {
     if (Array.isArray(second)) {
       interceptors = { interceptors: second };
     } else {
-      metadata = generateMeta(second);
+      const {options} = second;
+      delete second.options;
+      metadata = generateMeta(second, options);
     }
   }
   let callback = function(err, res) {