@@ -87,7 +87,7 @@ class Layer extends EventEmitter {
8787 await this . disconnect ( ) ;
8888
8989 /** Do not bubble up since close has already bubbled up */
90- internalDestroy ( this ) ;
90+ internalDestroy ( this , 'Close' ) ;
9191
9292 resolver . resolve ( ) ;
9393 } ) ;
@@ -104,14 +104,19 @@ class Layer extends EventEmitter {
104104
105105 forward ( data , info , context ) {
106106 if ( this . upperLayer != null ) {
107- this . forwardTo ( this . upperLayer , data , info , context ) ;
107+ return this . forwardTo ( this . upperLayer , data , info , context ) ;
108108 }
109109 }
110110
111111 forwardTo ( layer , data , info , context ) {
112- // console.log('emitting data');
113- // console.log(data);
114- internalHandleData ( layer , data , info , context ) ;
112+ if ( layer . _defragger != null ) {
113+ data = layer . _defragger . defrag ( data ) ;
114+ if ( data == null ) return ;
115+ }
116+ layer . emit ( 'data' , data , info , context ) ;
117+ return layer . handleData ( data , info , context ) ;
118+
119+ // return internalHandleData(layer, data, info, context);
115120 }
116121
117122 send ( message , info , priority , context ) {
@@ -227,14 +232,14 @@ function incrementContext(self) {
227232}
228233
229234
230- function internalHandleData ( self , data , info , context ) {
231- if ( self . _defragger != null ) {
232- data = self . _defragger . defrag ( data ) ;
233- if ( data == null ) return ;
234- }
235- self . emit ( 'data' , data , info , context ) ;
236- self . handleData ( data , info , context ) ;
237- }
235+ // function internalHandleData(self, data, info, context) {
236+ // if (self._defragger != null) {
237+ // data = self._defragger.defrag(data);
238+ // if (data == null) return;
239+ // }
240+ // self.emit('data', data, info, context);
241+ // return self.handleData(data, info, context);
242+ // }
238243
239244
240245function internalDestroy ( layer , error ) {
0 commit comments