gistfile1.js

var request = require("request");
var async = require("async");

module.exports = function (params, resultBus, callback) {
  var goldfeed = request.defaults({
    "url": params.url,
    "json": true,
    "timeout": params.timeout
  });

  var fetchCallback = require("../common").fetchCallback(resultBus.emit.bind(resultBus, "goldfeed"), params.interval);

  function fetch(callback) {
    goldfeed.get(null, function( err, response, body ) {
      console.log( '**** ' + ( new Date() ) + ' Gold-feed err, response, body:' );
      console.log( err );
      console.log( response );
      console.log( body );
      var originalCallback = fetchCallback( callback );
      originalCallback( arguments );
    } );
  }

  async.forever(fetch, callback);
};
~