THRIFT-2446: cause servers to emit stream errors
authorra <ra@apache.org>
Thu, 3 Apr 2014 15:55:18 +0000 (08:55 -0700)
committerra <ra@apache.org>
Thu, 3 Apr 2014 16:02:30 +0000 (09:02 -0700)
Client: node
Patch: alexey

Mods Thrift Node Servers to emit stream errors

This closes #94
----
commit 296f296db1d415b1d2a7bd8168f48cec5766a210
Author: gruzovator <gruzovator@gmail.com>
Date: 2014-04-03T15:16:07Z
nodejs server stream error handling

lib/nodejs/lib/thrift/server.js

index 06ee90b..715378c 100644 (file)
@@ -36,6 +36,9 @@ exports.createMultiplexServer = function(processor, options) {
 
   function serverImpl(stream) {
     var self = this;
+    stream.on('error', function(err) { 
+        self.emit('error', err); 
+    });
     stream.on('data', transport.receiver(function(transportWithData) {
       var input = new protocol(transportWithData);
       var output = new protocol(new transport(undefined, function(buf) {