var request = require('request');
var suspend = require('co-suspend');
 
module.exports.fetchContent = function * (url) {
  var marker = suspend();
 
  request('http://www.google.com', function (err, res, body) {
    marker.resume(err, body);
  });
 
  return yield marker.wait();  // return body
};

var fs = require('fs');
var suspend = require('co-suspend');
 
function * getFiles(path) {
  var marker = suspend();
  fs.readdir(path, marker.resume);
 
  return yield marker.wait();
}

var db = require('./some-db-module');
var suspend = require('co-suspend');
 
function * connect(conStr) {
  var marker = suspend();
 
  db.connect(conStr, marker.resume);
 
  return yield marker.wait(3000);  // wait 3 seconds
}

var connect;
 
try {
  connect = yield connect(dbConnectionString);
} catch (e) {
  console.error('Connection timeout!');
}

var marker = suspend();
var result;
 
someAsyncFunctionWithCallback(marker.resume);
result = yield marker.wait();
//....
 
otherAsyncFunctionWithCallback(marker.resume);
result = yield marker.wait();
//...
 
finalAsyncWithCallback(marker.resume);
result = yield marker.wait();
//...

var marker = suspend();
var result;
 
var q = db.query(selectQuery, marker.resume);
q.on('row', function (row) {
  marker.enqueue(function * () {
    // process row asynchronously... the marker will wait for this to return!
  });
 
  marker.enqueue(function (done) {
    // this works, too! In fact, anything co compatible will work just fine
    // as argument to .enqueue()
 
    setTimeout(done, 3000);
  });
});
 
result = yield marker.wait(QUERY_TIMEOUT);