Skip to content

Instantly share code, notes, and snippets.

@creationix
Created May 8, 2013 22:02
Show Gist options
  • Star 67 You must be signed in to star a gist
  • Fork 7 You must be signed in to fork a gist
  • Save creationix/5544019 to your computer and use it in GitHub Desktop.
Save creationix/5544019 to your computer and use it in GitHub Desktop.
Working version of generator async code sample. Using node from https://github.com/andywingo/node/tree/v8-3.19
tim@touchsmart:~/Code$ nvm use v0.11.2-generators
Now using node v0.11.2-generators
tim@touchsmart:~/Code$ node --harmony testgen.js
<Buffer 76 61 72 20 66 73 20 3d 20 72 65 71 75 69 72 65 28 27 66 73 27 29 3b 0a 66 75 6e 63 74 69 6f 6e 20 72 65 61 64 46 69 6c 65 28 70 61 74 68 2c 20 65 6e 63 ...>
Sleeping for 2000ms...
Done
var fs = require('fs');
function readFile(path, encoding) {
return function (callback) {
fs.readFile(path, encoding, callback);
};
}
function sleep(ms) {
return function (callback) {
setTimeout(callback, ms);
};
}
function run(makeGenerator) {
return function () {
var generator = makeGenerator.apply(this, arguments);
var continuable, sync, value;
next();
function next() {
while (!(continuable = generator.send(value)).done) {
continuable = continuable.value;
sync = undefined;
continuable(callback);
if (sync === undefined) {
sync = false;
break;
}
}
}
function callback(err, val) {
if (err) return generator.throw(err);
value = val;
if (sync === undefined) {
sync = true;
}
else {
next();
}
}
}
}
run(function* () {
console.log(yield readFile(__filename));
console.log("Sleeping for 2000ms...");
yield sleep(2000);
console.log("Done");
})();
@sultan99
Copy link

sultan99 commented Aug 20, 2016

I think it could be less code, correct me if I do wrong:

function asyn(generator) {
  var iterator = generator()
  var job = iterator.next()
  var next = function() {
    if (typeof(job.value) == "function") {
      job.value(function(error, val) {
        if (error) return console.error(error)
        job = iterator.next(val)
        if (!job.done) next()
      })
    }
  }
  next()
}

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment