Comment utiliser ES8 async/await avec des cours d'eau?

Dans https://stackoverflow.com/a/18658613/779159 est un exemple de la façon de calculer le md5 d'un fichier à l'aide de l'intégré dans la librairie de cryptographie et de ruisseaux.

var fs = require('fs');
var crypto = require('crypto');

//the file you want to get the hash    
var fd = fs.createReadStream('/some/file/name.txt');
var hash = crypto.createHash('sha1');
hash.setEncoding('hex');

fd.on('end', function() {
    hash.end();
    console.log(hash.read()); //the desired sha1sum
});

//read all file and pipe it (write it) to the hash object
fd.pipe(hash);

Mais est-il possible de convertir ce à l'aide de ES8 async/await au lieu d'utiliser la fonction de rappel comme vu ci-dessus, mais tout en gardant l'efficacité de l'aide de flux?

async/await n'est rien, mais la syntaxe de support au niveau de promesses. Si vous pouvez mettre ce code à l'intérieur d'une promesse, alors vous êtes fait.

OriginalL'auteur user779159 | 2015-11-08

  1. 53

    async/await ne fonctionne qu'avec des promesses, pas avec des cours d'eau. Il y a des idées pour fabriquer un flux de données de type qui serait sa propre syntaxe, mais ceux-ci sont encore très expérimental si à tout et je n'entrerai pas dans les détails.

    De toute façon, votre rappel est seulement en attente de la fin du flux, ce qui est un ajustement parfait pour une promesse. Vous avez juste à envelopper le stream:

    var fd = fs.createReadStream('/some/file/name.txt');
var hash = crypto.createHash('sha1');
hash.setEncoding('hex');
fd.on('end', function() {
    hash.end();
});
//read all file and pipe it (write it) to the hash object
fd.pipe(hash);

var end = new Promise(function(resolve, reject) {
    fd.on('end', ()=>resolve(hash.read()));
    fd.on('error', reject); //or something like that
});

    Maintenant, vous pouvez attendre que la promesse:

    (async function() {
    let sha1sum = await end;
    console.log(sha1sum);
}());
    Félicitations! Maintenant, il n'est pas un droit de réponse, vous pouvez maintenant utiliser asynchrone cycle de ruisseaux 2ality.com/2018/04/async-iter-nodejs.html. Malheureusement, c'est une fonctionnalité expérimentale maintenant.
    Donc tu veux dire que la réponse est fausse, car il n'est pas "très expérimental", mais simplement "expérimental"? 😀
    JS utilisation de promesses et async/await dans tous les async cas. C'est trop étrange, que ce fiature n'était pas publié dans la production. Je pense que c'est un bon sintacsys maintenant et ne sera pas changé.

    OriginalL'auteur Bergi

  2. 1

    Si vous utilisez le nœud de la version >= v10.0.0 vous pouvez utiliser flux de données.pipeline et util.promisify.

    const fs = require('fs');
const crypto = require('crypto');
const util = require('util');
const stream = require('stream');

const pipeline = util.promisify(stream.pipeline);

const hash = crypto.createHash('sha1');
hash.setEncoding('hex');

async function run() {
  await pipeline(
    fs.createReadStream('/some/file/name.txt'),
    hash
  );
  console.log('Pipeline succeeded');
}

run().catch(console.error);

    OriginalL'auteur shusson