1

ストリームを使用highland.jsしてファイルを処理し、2 つの区切り記号の間の内容を読み取ります。async.jsまた、一連の http リクエストを順番に実行するために使用しています。

理想的にはx、ハイランドからの出力を最初の関数としてasyncシリーズ (チェーン) に渡し、ストリームから抽出されたチャンクごとに HTTP 要求が実行されるようにしたいと考えています。

これは可能ですか？もしそうなら、どうすればこれを達成できますか？

var async = require('async');
var _ = require('highland');


_(fs.createReadStream(files[0], { encoding: 'utf8' }))
        .splitBy('-----BEGIN-----\n')
        .splitBy('\n-----END-----\n')
        .filter(chunk => chunk !== '')
        .each(function (x) {
        }).done(function () {

    async.series([
        function(callback) {
            setTimeout(function() {
                console.log('Task 1');
                callback(null, 1);
            }, 300);
        },
        function(callback) {
            setTimeout(function() {
                console.log('Task 2');
                callback(null, 2);
            }, 200);
        },
    ], function(error, results) {
        console.log(results);
    });

});;
4

1 に答える 1