File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -5,10 +5,6 @@ var events = require('events');
55var mpBindings = require ( 'mpBindings' ) ;
66var sys = require ( 'sys' ) ;
77
8- var debug = ( 'NODE_DEBUG' in process . env ) ?
9- function ( m ) { sys . error . apply ( this , arguments ) ; } :
10- function ( ) { } ;
11-
128var pack = mpBindings . pack ;
139var unpack = mpBindings . unpack ;
1410
@@ -34,14 +30,12 @@ var Stream = function(s) {
3430 args . push ( arguments [ i ] ) ;
3531 }
3632
37- s . write . apply ( s , args ) ;
33+ return s . write . apply ( s , args ) ;
3834 } ;
3935
4036 // Listen for data from the underlying stream, consuming it and emitting
4137 // 'msg' events as we find whole messages.
4238 s . addListener ( 'data' , function ( d ) {
43- debug ( 'received ' + d . length + ' bytes' ) ;
44-
4539 // Make sure that self.buf reflects the entirety of the unread stream
4640 // of bytes; it needs to be a single buffer
4741 if ( self . buf ) {
@@ -71,8 +65,6 @@ var Stream = function(s) {
7165 self . buf = null ;
7266 }
7367 }
74-
75- debug ( ( ( self . buf ) ? self . buf . length : 0 ) + ' bytes remaining' ) ;
7668 } ) ;
7769} ;
7870
You can’t perform that action at this time.
0 commit comments