diff --git a/lib/nodejs/lib/thrift/server.js b/lib/nodejs/lib/thrift/server.js
index 06ee90b..715378c 100644
--- a/lib/nodejs/lib/thrift/server.js
+++ b/lib/nodejs/lib/thrift/server.js
@@ -36,6 +36,9 @@
 
   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) {