summaryrefslogtreecommitdiff
path: root/test/detect.js
diff options
context:
space:
mode:
Diffstat (limited to 'test/detect.js')
-rw-r--r--test/detect.js72
1 files changed, 36 insertions, 36 deletions
diff --git a/test/detect.js b/test/detect.js
index b1ebf24..4bda08f 100644
--- a/test/detect.js
+++ b/test/detect.js
@@ -2,10 +2,10 @@ var async = require('../lib');
var expect = require('chai').expect;
var _ = require('lodash');
-describe("detect", function () {
+describe("detect", () => {
function detectIteratee(call_order, x, callback) {
- setTimeout(function(){
+ setTimeout(() => {
call_order.push(x);
callback(null, x == 2);
}, x*5);
@@ -13,12 +13,12 @@ describe("detect", function () {
it('detect', function(done){
var call_order = [];
- async.detect([3,2,1], detectIteratee.bind(this, call_order), function(err, result){
+ async.detect([3,2,1], detectIteratee.bind(this, call_order), (err, result) => {
call_order.push('callback');
expect(err).to.equal(null);
expect(result).to.equal(2);
});
- setTimeout(function(){
+ setTimeout(() => {
expect(call_order).to.eql([1,2,'callback',3]);
done();
}, 25);
@@ -26,21 +26,21 @@ describe("detect", function () {
it('detect - mulitple matches', function(done){
var call_order = [];
- async.detect([3,2,2,1,2], detectIteratee.bind(this, call_order), function(err, result){
+ async.detect([3,2,2,1,2], detectIteratee.bind(this, call_order), (err, result) => {
call_order.push('callback');
expect(err).to.equal(null);
expect(result).to.equal(2);
});
- setTimeout(function(){
+ setTimeout(() => {
expect(call_order).to.eql([1,2,'callback',2,2,3]);
done();
}, 25);
});
- it('detect error', function(done){
- async.detect([3,2,1], function(x, callback) {
- setTimeout(function(){callback('error');}, 0);
- }, function(err, result){
+ it('detect error', (done) => {
+ async.detect([3,2,1], (x, callback) => {
+ setTimeout(() => {callback('error');}, 0);
+ }, (err, result) => {
expect(err).to.equal('error');
expect(result).to.not.exist;
done();
@@ -49,12 +49,12 @@ describe("detect", function () {
it('detectSeries', function(done){
var call_order = [];
- async.detectSeries([3,2,1], detectIteratee.bind(this, call_order), function(err, result){
+ async.detectSeries([3,2,1], detectIteratee.bind(this, call_order), (err, result) => {
call_order.push('callback');
expect(err).to.equal(null);
expect(result).to.equal(2);
});
- setTimeout(function(){
+ setTimeout(() => {
expect(call_order).to.eql([3,2,'callback']);
done();
}, 50);
@@ -62,36 +62,36 @@ describe("detect", function () {
it('detectSeries - multiple matches', function(done){
var call_order = [];
- async.detectSeries([3,2,2,1,2], detectIteratee.bind(this, call_order), function(err, result){
+ async.detectSeries([3,2,2,1,2], detectIteratee.bind(this, call_order), (err, result) => {
call_order.push('callback');
expect(err).to.equal(null);
expect(result).to.equal(2);
});
- setTimeout(function(){
+ setTimeout(() => {
expect(call_order).to.eql([3,2,'callback']);
done();
}, 50);
});
- it('detect no callback', function(done) {
+ it('detect no callback', (done) => {
var calls = [];
- async.detect([1, 2, 3], function (val, cb) {
+ async.detect([1, 2, 3], (val, cb) => {
calls.push(val);
cb();
});
- setTimeout(function () {
+ setTimeout(() => {
expect(calls).to.eql([1, 2, 3]);
done();
}, 10);
});
- it('detectSeries - ensure stop', function (done) {
- async.detectSeries([1, 2, 3, 4, 5], function (num, cb) {
+ it('detectSeries - ensure stop', (done) => {
+ async.detectSeries([1, 2, 3, 4, 5], (num, cb) => {
if (num > 3) throw new Error("detectSeries did not stop iterating");
cb(null, num === 3);
- }, function (err, result) {
+ }, (err, result) => {
expect(err).to.equal(null);
expect(result).to.equal(3);
done();
@@ -100,12 +100,12 @@ describe("detect", function () {
it('detectLimit', function(done){
var call_order = [];
- async.detectLimit([3, 2, 1], 2, detectIteratee.bind(this, call_order), function(err, result) {
+ async.detectLimit([3, 2, 1], 2, detectIteratee.bind(this, call_order), (err, result) => {
call_order.push('callback');
expect(err).to.equal(null);
expect(result).to.equal(2);
});
- setTimeout(function() {
+ setTimeout(() => {
expect(call_order).to.eql([2, 'callback', 3]);
done();
}, 50);
@@ -113,63 +113,63 @@ describe("detect", function () {
it('detectLimit - multiple matches', function(done){
var call_order = [];
- async.detectLimit([3,2,2,1,2], 2, detectIteratee.bind(this, call_order), function(err, result){
+ async.detectLimit([3,2,2,1,2], 2, detectIteratee.bind(this, call_order), (err, result) => {
call_order.push('callback');
expect(err).to.equal(null);
expect(result).to.equal(2);
});
- setTimeout(function(){
+ setTimeout(() => {
expect(call_order).to.eql([2, 'callback', 3]);
done();
}, 50);
});
- it('detectLimit - ensure stop', function (done) {
- async.detectLimit([1, 2, 3, 4, 5], 2, function (num, cb) {
+ it('detectLimit - ensure stop', (done) => {
+ async.detectLimit([1, 2, 3, 4, 5], 2, (num, cb) => {
if (num > 4) throw new Error("detectLimit did not stop iterating");
cb(null, num === 3);
- }, function (err, result) {
+ }, (err, result) => {
expect(err).to.equal(null);
expect(result).to.equal(3);
done();
});
});
- it('detectSeries doesn\'t cause stack overflow (#1293)', function(done) {
+ it('detectSeries doesn\'t cause stack overflow (#1293)', (done) => {
var arr = _.range(10000);
let calls = 0;
- async.detectSeries(arr, function(data, cb) {
+ async.detectSeries(arr, (data, cb) => {
calls += 1;
async.setImmediate(_.partial(cb, null, true));
- }, function(err) {
+ }, (err) => {
expect(err).to.equal(null);
expect(calls).to.equal(1);
done();
});
});
- it('detectLimit doesn\'t cause stack overflow (#1293)', function(done) {
+ it('detectLimit doesn\'t cause stack overflow (#1293)', (done) => {
var arr = _.range(10000);
let calls = 0;
- async.detectLimit(arr, 100, function(data, cb) {
+ async.detectLimit(arr, 100, (data, cb) => {
calls += 1;
async.setImmediate(_.partial(cb, null, true));
- }, function(err) {
+ }, (err) => {
expect(err).to.equal(null);
expect(calls).to.equal(100);
done();
});
});
- it('find alias', function(){
+ it('find alias', () => {
expect(async.find).to.equal(async.detect);
});
- it('findLimit alias', function(){
+ it('findLimit alias', () => {
expect(async.findLimit).to.equal(async.detectLimit);
});
- it('findSeries alias', function(){
+ it('findSeries alias', () => {
expect(async.findSeries).to.be.a('function');
expect(async.findSeries).to.equal(async.detectSeries);
});