Lines Matching refs:debug
51 let debug = require('internal/util/debuglog').debuglog('stream', (fn) => {
52 debug = fn;
287 debug('readableAddChunk', chunk);
447 debug('read', n);
474 debug('read: emitReadable', state.length, state.ended);
515 debug('need readable', doRead);
520 debug('length less than watermark', doRead);
529 debug('reading, ended or constructing', doRead);
531 debug('do read');
589 debug('onEofChunk');
620 debug('emitReadable', state.needReadable, state.emittedReadable);
623 debug('emitReadable', state.flowing);
631 debug('emitReadable_', state.destroyed, state.length, state.ended);
692 debug('maybeReadMore read 0');
723 debug('pipe count=%d opts=%j', state.pipes.length, pipeOpts);
737 debug('onunpipe');
747 debug('onend');
755 debug('cleanup');
787 debug('false write response, pause', 0);
791 debug('false write response, pause', state.awaitDrainWriters.size);
808 debug('ondata');
810 debug('dest.write', ret);
819 debug('onerror', er);
843 debug('onfinish');
850 debug('unpipe');
862 debug('pipe resume');
877 debug('pipeOnDrain', 1);
880 debug('pipeOnDrain', state.awaitDrainWriters.size);
944 debug('on readable', state.length, state.reading);
1010 debug('readable nexttick read 0');
1019 debug('resume');
1038 debug('resume', state.reading);
1051 debug('call pause flowing=%j', this._readableState.flowing);
1053 debug('pause');
1063 debug('flow', state.flowing);
1386 debug('endReadable', state.endEmitted);
1394 debug('endReadableNT', state.endEmitted, state.length);