verdnatura-mirror
/
loopback-datasource-juggler
mirror of https://github.com/loopbackio/loopback-datasource-juggler
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Use async for flow control

This commit is contained in:
Raymond Feng 2014-06-20 12:05:42 -07:00
parent a1836662a7
commit b07c36eab7
2 changed files with 11 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
test/basic-querying.test.js
View File

@ -1,5 +1,6 @@
// This test written in mocha+should.js // This test written in mocha+should.js
var should = require('./init.js'); var should = require('./init.js');
var async = require('async');
var db, User; var db, User;
describe('basic-querying', function () { describe('basic-querying', function () {
@ -578,7 +579,6 @@ describe('basic-querying', function () {
}); });
function seed(done) { function seed(done) {
var count = 0;
var beatles = [ var beatles = [
{ {
seq: 0, seq: 0,
@ -603,15 +603,11 @@ function seed(done) {
{seq: 4, name: 'Pete Best', order: 4}, {seq: 4, name: 'Pete Best', order: 4},
{seq: 5, name: 'Stuart Sutcliffe', order: 3, vip: true} {seq: 5, name: 'Stuart Sutcliffe', order: 3, vip: true}
]; ];
User.destroyAll(function () {
beatles.forEach(function (beatle) {
User.create(beatle, ok);
});
});
function ok() { async.series([
if (++count === beatles.length) { User.destroyAll.bind(User),
done(); function(cb) {
async.each(beatles, User.create.bind(User), cb);
} }
} ], done);
} }

15
test/memory.test.js
View File

@ -142,7 +142,6 @@ describe('Memory connector', function () {
}); });
function seed(done) { function seed(done) {
var count = 0;
var beatles = [ var beatles = [
{ {
seq: 0, seq: 0,
@ -167,17 +166,13 @@ describe('Memory connector', function () {
{seq: 4, name: 'Pete Best', order: 4}, {seq: 4, name: 'Pete Best', order: 4},
{seq: 5, name: 'Stuart Sutcliffe', order: 3, vip: true} {seq: 5, name: 'Stuart Sutcliffe', order: 3, vip: true}
]; ];
User.destroyAll(function () {
beatles.forEach(function (beatle) {
User.create(beatle, ok);
});
});
function ok() { async.series([
if (++count === beatles.length) { User.destroyAll.bind(User),
done(); function(cb) {
async.each(beatles, User.create.bind(User), cb);
} }
} ], done);
} }
}); });