Node.js 15回の反復処理を行った後、読み込み可能なself.push（）が終了する

Question

このコードのReadable = require('stream').Readableがnode.jsで15回しか動作しない理由を理解しようとしています。この行を省略すると、この行は無期限に繰り返されます。これは正しいです。

start.js

console.log('Start Therm'); 
const thermom = require('./therm.js'); 

var X = new thermom(); 
X._read(); 

X.on('start',function() {console.log('start')}); 

// X.on('data',function() {console.log('data')}); 

X.on('end',function() {console.log('end')}); 
X.on('error',function() {console.log('error')}); 

therm.js

var Readable = require('stream').Readable; 
var util = require('util'); 
var _ = require('lodash'); 
var count=0; 
function getTemperatureReadingFromThermometer(cb) { 
    setTimeout(function() { 
    cb(null, Math.round(Math.random() * 20 * 100)/100) 
    }, 10); 
} 


module.exports = Thermometer; 

function Thermometer(options) { 
    this.count = 0; 
    if (! (this instanceof Thermometer)) { 
    return new Thermometer(options); 
    } 
    if (! options) { 
    options = {}; 
    } 
    options.objectMode = true; 
    Readable.call(this, options); 

} 

util.inherits(Thermometer, Readable); 


Thermometer.prototype._read = function read() { 
    var self = this; 

    getTemperatureReadingFromThermometer(
    function(err, temperature) { 
    console.log('getTemperatureReadingFromThermometer :' + temperature); 
    if (err) { 
     self.emit('error', err); 
    } else { 
     console.log('self.push(temperature) : ' + count++); 
     self.push(); 
    } 
    }); 
}; 

ノードstart.js出力わずか15回の反復。

Start Therm 
getTemperatureReadingFromThermometer :7.98 
self.push(temperature) : 0 
getTemperatureReadingFromThermometer :18.46 
self.push(temperature) : 1 
getTemperatureReadingFromThermometer :13.27 
self.push(temperature) : 2 
getTemperatureReadingFromThermometer :1.6 
self.push(temperature) : 3 
getTemperatureReadingFromThermometer :18.08 
self.push(temperature) : 4 
getTemperatureReadingFromThermometer :2.08 
self.push(temperature) : 5 
getTemperatureReadingFromThermometer :10.91 
self.push(temperature) : 6 
getTemperatureReadingFromThermometer :13 
self.push(temperature) : 7 
getTemperatureReadingFromThermometer :9.98 
self.push(temperature) : 8 
getTemperatureReadingFromThermometer :14.4 
self.push(temperature) : 9 
getTemperatureReadingFromThermometer :6.69 
self.push(temperature) : 10 
getTemperatureReadingFromThermometer :12.14 
self.push(temperature) : 11 
getTemperatureReadingFromThermometer :3.65 
self.push(temperature) : 12 
getTemperatureReadingFromThermometer :13.54 
self.push(temperature) : 13 
getTemperatureReadingFromThermometer :16.59 
self.push(temperature) : 14 
getTemperatureReadingFromThermometer :1.69 
self.push(temperature) : 15 

任意のヒントを大幅に

Answer 1

をいただければ幸い私は最終的にこの苦境への答えを見つけました。

var X = new thermom({highWaterMark: 500 }); 

も同様に、5のhighwatermarkのは、ここでのNode.js https://nodejs.org/api/stream.html#stream_new_stream_readable_options

に文書のみ5.そのに反復を低減するであろう、このキューであなたに500項目のバッファを与えるだろう