Merge pull request uber#1197 from uber/fix_relay_handler

relay_handler: fix for no streamed arg1
benfleis · Aug 21, 2015 · 1765baf · 1765baf
2 parents 8ee83cc + 0eff12c
commit 1765baf
Showing 1 changed file with 1 addition and 11 deletions.
diff --git a/node/relay_handler.js b/node/relay_handler.js
@@ -159,16 +159,7 @@ RelayRequest.prototype.onIdentified = function onIdentified(err1) {
     self.outreq.errorEvent.on(onError);
 
     if (self.outreq.streamed) {
-        // TODO: frame-at-a-time rather than re-streaming?
-
-        var arg1 = self.inreq.arg1;
-        if (arg1.buf) {
-            arg1 = arg1.buf;
-        }
-
-        self.outreq.sendStreams(
-            arg1, self.inreq.arg2, self.inreq.arg3
-        );
+        self.outreq.sendStreams(self.inreq.arg1, self.inreq.arg2, self.inreq.arg3);
     } else {
         self.outreq.send(self.inreq.arg1, self.inreq.arg2, self.inreq.arg3);
     }
@@ -237,7 +228,6 @@ RelayRequest.prototype.onResponse = function onResponse(res) {
     })) return;
 
     if (self.outres.streamed) {
-        self.outres.arg1.end();
         self.inres.arg2.pipe(self.outres.arg2);
         self.inres.arg3.pipe(self.outres.arg3);
     } else {