ジェネレータ関数でストリームを生成する

Question

私は最近、約束をもたらすジェネレータを実行するためにQ.spawn関数を使用し始めました。これは、ストリームのサポートがまだ開始されていないブラウザーではうまくいきますが、ノードの場合はストリームがあります。ジェネレータ関数内でストリームを使用していて、ライターストリームが完了すると、コードがきれいになることはありません。

Q.spawn(function*() { 
    yield new Promise(resolve => { 
    let fromStream = fs.createReadStream('x.txt'); 
    let toStream = fs.createWriteStream('y.txt'); 

    toStream.on('end',() => resolve()); 
    fromStream.pipe(toStream); 
    }); 
}); 

これはうまくいきますが、多くのストリームを処理し始めると、コードは実際には醜いものになります。スニペットのように簡単にできますか？

someGeneratorFuncRunner(function*() { 
    yield fs.createReadStream('x.txt') 
      .pipe(fs.createWriteStream('y.txt')); 
}); 

Answer 1

あなたはPromiseコンストラクタ内でそのコードのほとんどを配置する必要がありません。

Q.spawn(function*() { 
    let fromStream = fs.createReadStream('x.txt'); 
    let toStream = fs.createWriteStream('y.txt'); 

    fromStream.pipe(toStream); 
    yield new Promise(resolve => { 
    toStream.on('end', resolve); 
    }); 
}); 

そしてもちろん、あなたがストリームの多くを待っているならば、それはアウト考慮に理にかなってヘルパー関数への約束コンストラクタ呼び出し：

function endOf(stream) { 
    return new Promise(resolve => { 
    stream.on('end', resolve); 
    }); 
}