Correct 'Make backend streams write objects'

share · Jun 16, 2016 · 7ae77c9 · 7ae77c9
1 parent c676077
commit 7ae77c9
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/lib/client/connection.js b/lib/client/connection.js
@@ -410,7 +410,7 @@ Connection.prototype.send = function(message) {
   if (this.debug) console.log('SEND', JSON.stringify(message));
 
   this.emit('send', message);
-  this.socket.send(message);
+  this.socket.send(JSON.stringify(message));
 };
 
 

diff --git a/lib/stream-socket.js b/lib/stream-socket.js
@@ -22,7 +22,7 @@ StreamSocket.prototype.close = function(reason) {
 };
 StreamSocket.prototype.send = function(data) {
   // Data is an object
-  this.stream.push(data);
+  this.stream.push(JSON.parse(data));
 };
 StreamSocket.prototype.onmessage = util.doNothing;
 StreamSocket.prototype.onclose = util.doNothing;
@@ -56,7 +56,7 @@ ServerStream.prototype._write = function(chunk, encoding, callback) {
   var socket = this.socket;
   process.nextTick(function() {
     if (socket.readyState !== 1) return;
-    socket.onmessage({data: chunk});
+    socket.onmessage({data: JSON.stringify(chunk)});
     callback();
   });
 };