nl_tokens: / * This is a very simple buffer for a predetermined set of events . It is unbounded . It forwards all arguments to any outlet emitter attached with sync () .
pl_tokens: function ( src , events ) { // By default, we service the default stream events var self = this , streamEvents = [ 'data' , 'end' , 'error' , 'close' , 'fd' , 'drain' , 'pipe' ] ; this . events = events || streamEvents ; this . emitter = src ; this . eventBuffer = [ ] ; this . outlet = null ; this . events . forEach ( function ( name ) { self . emitter . addListener ( name , function ( ) { self . proxyEmit ( <mask> , arguments ) ; } ) ; } ) ; }