UNPKG

552 BJavaScriptView Raw
1var mod_vasync = require('../lib/vasync');
2
3var barrier = mod_vasync.barrier();
4
5barrier.on('drain', function () {
6 console.log('barrier drained!');
7});
8
9console.log('barrier', barrier);
10
11barrier.start('op1');
12console.log('op1 started', barrier);
13
14barrier.start('op2');
15console.log('op2 started', barrier);
16
17barrier.done('op2');
18console.log('op2 done', barrier);
19
20barrier.done('op1');
21console.log('op1 done', barrier);
22
23barrier.start('op3');
24console.log('op3 started');
25
26setTimeout(function () {
27 barrier.done('op3');
28 console.log('op3 done');
29}, 10);