Új hozzászólás Aktív témák

• PumpkinSeed addikt

  #6551

  #6550 Jim-Y

  2017-05-12 14:45:04

  Új Válasz

  Új hozzászólás

  Összes hozzászólása itt Válaszok az összes hozzászólására itt Válaszok erre a hozzászólásra

  

  PumpkinSeed

  addikt

  #6550 Jim-Y

  #6550 Jim-Y

  Szia,

  Köszi a választ de szerintem félreértettél valamit vagy én nem foglalkoztam egyértelműen. Nekem valami ilyesmire lenne szükségem. Pseudo

  this
.readFileAsStream()
.pipe(parser)
.pipe(
this.pause();
asyncFunction((err, data) => {
this.resume();
})
)
.pipe(stremToDb)

  Most az a bajom, hogy a fájl fejlécének kiolvasása után kéne csinálnom egy DB táblát majd belestreamelni a fájl tartalmát. A tábla létrehozása async művelet és nem tudok olyan pipe függvényt írni ami ezidőre felfüggesztené a futást :/

  Értem, viszont ezzel a pipe-al az a baj, hogy azért lett létrehozva, hogy úgy kezeld le a folyamat, hogy mindent ő csinál meg, szóval anélkül, hogy te menedzseled a folyamatot. Viszont ha valami ilyesmit használsz akkor minden chunk esetén te kezeled le, hogy mi történjen vele.

  var fs = require('fs');
var readableStream = fs.createReadStream('file.txt');
var data = '';
var chunk;

readableStream.on('readable', function() {
while ((chunk=readableStream.read()) != null) {
data += chunk;
}
});

readableStream.on('end', function() {
console.log(data)
});

  Lehet, hogy ez nem pont az amit te keresel.

Új hozzászólás Aktív témák