diff options
Diffstat (limited to 'test/retryable.js')
-rw-r--r-- | test/retryable.js | 30 |
1 files changed, 15 insertions, 15 deletions
diff --git a/test/retryable.js b/test/retryable.js index 48d9ee9..fe04db0 100644 --- a/test/retryable.js +++ b/test/retryable.js @@ -2,44 +2,44 @@ var async = require('../lib'); var expect = require('chai').expect; var assert = require('assert'); -describe('retryable', function () { - it('basics', function (done) { +describe('retryable', () => { + it('basics', (done) => { var calls = 0; - var retryableTask = async.retryable(3, function (arg, cb) { + var retryableTask = async.retryable(3, (arg, cb) => { calls++; expect(arg).to.equal(42); cb('fail'); }); - retryableTask(42, function (err) { + retryableTask(42, (err) => { expect(err).to.equal('fail'); expect(calls).to.equal(3); done(); }); }); - it('basics with error test function', function (done) { + it('basics with error test function', (done) => { var calls = 0; var special = 'special'; var opts = { - errorFilter: function(err) { + errorFilter(err) { return err == special; } }; - var retryableTask = async.retryable(opts, function (arg, cb) { + var retryableTask = async.retryable(opts, (arg, cb) => { calls++; expect(arg).to.equal(42); cb(calls === 3 ? 'fail' : special); }); - retryableTask(42, function (err) { + retryableTask(42, (err) => { expect(err).to.equal('fail'); expect(calls).to.equal(3); done(); }); }); - it('should work as an embedded task', function(done) { + it('should work as an embedded task', (done) => { var retryResult = 'RETRY'; var fooResults; var retryResults; @@ -50,29 +50,29 @@ describe('retryable', function () { fooResults = results; callback(null, 'FOO'); }], - retry: ['dep', async.retryable(function(results, callback) { + retry: ['dep', async.retryable((results, callback) => { retryResults = results; callback(null, retryResult); })] - }, function(err, results){ + }, (err, results) => { assert.equal(results.retry, retryResult, "Incorrect result was returned from retry function"); assert.equal(fooResults, retryResults, "Incorrect results were passed to retry function"); done(); }); }); - it('should work as an embedded task with interval', function(done) { + it('should work as an embedded task with interval', (done) => { var start = new Date().getTime(); var opts = {times: 5, interval: 20}; async.auto({ - foo: function(callback){ + foo(callback){ callback(null, 'FOO'); }, - retry: async.retryable(opts, function(callback) { + retry: async.retryable(opts, (callback) => { callback('err'); }) - }, function(){ + }, () => { var duration = new Date().getTime() - start; var expectedMinimumDuration = (opts.times -1) * opts.interval; assert(duration >= expectedMinimumDuration, |