/ / नोड पाइप हैंडल इनपुट - node.js, asynchronous, नोड-स्ट्रीम

नोड पाइप हैंडल इनपुट - node.js, asynchronous, नोड-स्ट्रीम

मैं एक टेक्स्टफाइल से दूसरे पाइप में डेटा पाइप कर रहा हूँजो कुछ यूआरएल से छवियों को डाउनलोड कर रहा है। अब उम्मीद है कि यह त्वरित उत्तराधिकार में बड़ी संख्या में अनुरोध भेजता है और रिमोट सर्वर मुझे बंद कर देता है। पहले संसाधित होने के बाद ही मैं अगले खंड को संभालना चाहता हूं। मेरा कोड है:

read.pipe(JSONStream.parse("*"))
.pipe(es.map(function (d, cb) {
download_images(x,y)
.then(function(r) ...)
.fail(function(r)  ...)
.fin(function(f) cb())
})
.pipe(xyz)

चूंकि मैंने अभी स्ट्रीमों की तलाश शुरू कर दी है, इसलिए शायद मैंने एक बहुत ही सरल बिंदु याद किया होगा, या धाराओं का उपयोग करने के अपने उत्साह में मैं एक बेहतर दृष्टिकोण को अनदेखा कर सकता था

  • बेहद बड़ी जेसन फ़ाइल
  • देरी के साथ छवियों को डाउनलोड करें

उत्तर:

जवाब के लिए 0 № 1

आप कॅाल कर सकते हैं read.pause() कॉल करने से ठीक पहले download_images() और फिर कॉल करें read.resume() कॉल करने से ठीक पहले cb().