laser

Some notes about the gist:

• Calling "sync" creates an array to keep track of return values from any asynchronous operation.

• The "resume" method is called in your generator code and its return value is passed as the callback to your asynchronous operation. Calling "resume" causes a counter to increment, letting your "sync" method know how many asynchronous operations are in flight.

• The return value of "resume" is a function that causes the result of the asynchronous operation to be placed into the data structure in #1. Immediately after doing this assignment, we check to see if there are any outstanding asynchronous operations. If not, we resume the generator with either an (ordered) array containing the results of our asynchronous operations or (in the event of only one operation having been fired off)

The important thing to note is that both asynchronous operations have been fired off before yielding. Each callback (passed to these asynchronous calls) is the return value from the call to "resume" -

laser

app.get('/home', prioritize(prioritizer, responder));

var queues = [];

function flush() {
  if (!flush.polling) {
    flush.polling = setInterval(function() {
      var x;
      for (var i = 0; i < queues.length; i++) {
        for (var j = 0; j < queues[i].length; j++) {

laser

// async

async.waterfall([
  function(callback) {
    async.parallel([
      function(callback) {
        _get("/token", callback);
      },
      function(callback) {
        _post("/key", callback);

laser

sync(function* (resume) {
  var oneAndTwo = yield [_get("test1.txt", resume()), _get("test2.txt", resume())]
  var three     = yield _get("test3.txt", resume())
  
  log(oneAndTwo[0] + " - " + oneAndTwo[1] + " " + three)
});

laser

function sync(gen) {
  var iterable, resume;

  resume = function(err, retVal) {
    if (err) iterable.raise(err); // raise!
    iterable.next(retVal);
  };

  iterable = gen(resume);
  iterable.next();

laser

try {
  firstAsync(function(err, a) {
    if (err) { console.log(err); throw err; }
    secondAsync(function(err, b) {
      if (err) { console.log(err); throw err; }
      thirdAsync(function(err, c) {
        if (err) { console.log(err); throw err; }
        callback(a, b, c);
      });    
    });

laser

// **************
// framework code

function sync(gen) {
  var iterable, resume;

  resume = function(err, retVal) {
    if (err) iterable.raise(err);
    iterable.next(retVal); // resume!  
  };

laser

function* powGenerator() {
  var result = Math.pow(----10----, ----2----);
  return result;
}

laser

function* powGenerator() {
  var result = Math.pow(----10----, yield "b");
  return result;
}

laser

function* powGenerator() {
  var result = Math.pow(yield "a", yield "b");
  return result;
}

var g = powGenerator();
console.log(g.next().value);   // "a", from the first yield
console.log(g.next(10).value); // "b", from the second
console.log(g.next(2).value);  // 100, the result