Lines Matching defs:read
129 // not happen before the first read call.
166 // Object stream flag. Used to make read(n) ignore n and to
232 if (typeof options.read === 'function')
233 this._read = options.read;
273 // Manually shove something into the read() buffer.
281 // Unshift should *always* be something directly out of read().
446 Readable.prototype.read = function(n) {
447 debug('read', n);
465 // If we're doing read(0) to trigger a readable event, but we
474 debug('read: emitReadable', state.length, state.ended);
495 // the state of the read buffer, providing enough data when
500 // a read from the buffer.
507 // Take note if the _read call is sync or async (ie, if the read call
517 // If we currently have less than the highWaterMark, then also read some.
531 debug('do read');
537 // Call internal read method
575 // If we tried to read() past the EOF, then emit end on the next tick.
603 // the readable code triggers during a read() call.
616 // another read() call => stack overflow. This way, it might trigger
652 // and called read() to consume some data. that may have triggered
656 // then go ahead and try to read some more preemptively.
665 // Attempt to read more data if we should.
672 // when the stream consumer calls read() instead.
674 // the loop below is responsible for ensuring read() is called. Failing to
675 // call read here would abort the flow and there's no other mechanism for
680 // conditions prevent the data from being read:
682 // - There is already a pending 'read' operation (state.reading). This is a
686 // read()s. The execution ends in this method again after the _read() ends
692 debug('maybeReadMore read 0');
693 stream.read(0);
1010 debug('readable nexttick read 0');
1011 self.read(0);
1040 stream.read(0);
1047 stream.read(0);
1064 while (state.flowing && stream.read() !== null);
1131 if (typeof stream.read !== 'function') {
1163 const chunk = stream.destroyed ? null : stream.read();
1376 // read part of list.