Example of retry for operations that use EventEmitter and not Callback about node-retry HOT 7 CLOSED

var operation = retry.operation();
var t = new Task();
t.on('error', function(err) {
 operation.retry(err);
});

operation.attempt(function (currentAttempt) {
    t.execute();
});

var net = require('net');
var retry = require('retry');
var async = require('async');


function tryConnect(HOST, PORT, cb) {
  var client = new net.Socket();
  var operation = retry.operation();
  var cbCalled = false;

  client.on('error', function(err) {
    console.log('error');
    operation.retry(err);
  });

  operation.attempt(function (currentAttempt) {
    client.connect(PORT, HOST, function(){
      console.log('CONNECTED TO: ' + HOST + ':' + PORT);
      if(!cbCalled) {      
        cb();
        cbCalled = true;
      }
    });
  });
}

async.parallel(
    [
    function(cb) {
      tryConnect('localhost', 5672, cb);
    },

    function(cb) {
      tryConnect('localhost', 27017, cb);
    }
    ], 
    function() { 
      console.log('both connected') 
    }
    )

if(!operation.retry(err)) {
  cb(err, null)
}