How to use ES8 async/await with streams?

by

async/await only works with promises, not with streams. There are ideas to make an extra stream-like data type that would get its own syntax, but those are highly experimental if at all and I won’t go into details.

Anyway, your callback is only waiting for the end of the stream, which is a perfect fit for a promise. You’d just have to wrap the stream:

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

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

Now you can await that promise:

(async function() {
    let sha1sum = await end;
    console.log(sha1sum);
}());

More Related Contents:

  1. How can I use async/await at the top level?
  2. Using async/await with a forEach loop
  3. Is it an anti-pattern to use async/await inside of a new Promise() constructor?
  4. async/await implicitly returns promise?
  5. Combination of async function + await + setTimeout
  6. Use async await with Array.map
  7. Correct Try…Catch Syntax Using Async/Await
  8. Waiting for more than one concurrent await operation
  9. Async/Await Class Constructor
  10. async/await always returns promise
  11. How to return values from async functions using async-await from function? [duplicate]
  12. How to “await” for a callback to return?
  13. How can I wait In Node.js (JavaScript)? l need to pause for a period of time
  14. SyntaxError: Unexpected token function – Async Await Nodejs
  15. Using filesystem in node.js with async / await
  16. Why do I need to await an async function when it is not supposedly returning a Promise?
  17. Why are await and async valid variable names?
  18. Is there a way to wrap an await/async try/catch block to every function?
  19. Understanding async/await on NodeJS
  20. Will async/await block a thread node.js
  21. using async await and .then together
  22. How to know if a function is async?
  23. Node.js Async/Await module export
  24. async/await inside arrow functions (Array#map/filter)
  25. Is async await truly non-blocking in the browser?
  26. Difference of using async / await vs promises?
  27. Node.js mongodb driver async/await queries
  28. Does an async function always need to be called with await?
  29. ASYNC / AWAIT SyntaxError: await is only valid in async functions and the top level bodies of modules
  30. Why I got document is not defined error in puppeteer?

Leave a Comment