Wrapping fs.readFile in a generator/yield

Question

I'm trying to get my head around generators and yield in JavaScript and Node.js, but having an issue.

Ideally, what I'd want to do is wrap fs.readFile with generators/yield, so that I can use it synchronously without blocking anything.

I've come up with the following code:

function readFileSync (path) {
    return (function *(){
        return yield require('fs').readFile(path, function *(err, data){
            yield data;
        });
    })();
}

console.log(readFileSync('test-file.txt'));

But, unfortunately, readFileSync just always returns {} instead of the file content.

Hopefully what I want to achieve is still possible, or perhaps I've completely missed the point of generators/yield and I'm using it entirely incorrectly, in which case pointing out where I've gone wrong and any resources would be great.

Answer 1

How about using node with harmony features enabled (node --harmony) and this super simple ES6 snippet :

function run( gen, iter) {
  (iter=gen( (err, data) => (err && iter.raise(err)) || iter.next(data))).next();
}

run(function* (resume) {
    var contents = yield require('fs').readFile(path, resume);
    console.log(contents);
});

You can read more about this dead simple pattern (and try it out online) at this article at orangevolt.blogspot.com

Answer 2

Just a bit desugerifying and update (seems raise is renamed to throw) lgersman's answer to make it work with io.js 1.0.4:

function run(gen) {
  var iter = gen(function (err, data) {
    if (err) { iter.throw(err); }
    return iter.next(data);
  });
  iter.next();
}

run(function* (resume) {
  var contents = yield require('fs').readFile(path, resume);
  console.log(contents);
});

Thank you lgersman!

Answer 3

You can use a helper lib like Wait.for-ES6 (I'm the author)

Pro's: You can call sequentially any standard async node.js function

Con's: You can only do it inside a generator function*

Example using fs.readdir and fs.readfile (both are standard async node.js functions)

var wait=require('wait.for-es6'), fs=require('fs');

function* sequentialTask(){
   var list = yield wait.for(fs.readdir,'/home/lucio');
   console.log(list); // An array of files
   var data = yield wait.for(fs.readFile,list[0]); //read first file
   console.log(data); // contents
}

wait.launchFiber(sequentialTask);