1 | var fs = require('fs');
|
2 | var Promise = require('bluebird');
|
3 | var async = require('..').async;
|
4 | var await = require('..').await;
|
5 |
|
6 |
|
7 | var someNums = async.iterable (function (yield_) {
|
8 |
|
9 | await (Promise.delay(500));
|
10 | yield_(111);
|
11 | await (Promise.delay(500));
|
12 | yield_(222);
|
13 | await (Promise.delay(500));
|
14 | yield_(333);
|
15 | await (Promise.delay(500));
|
16 | });
|
17 |
|
18 |
|
19 | var program = async (function() {
|
20 | var iterator = someNums();
|
21 |
|
22 | await (iterator.forEach(console.log));
|
23 |
|
24 |
|
25 |
|
26 |
|
27 |
|
28 |
|
29 |
|
30 | return 'Finished!';
|
31 | });
|
32 |
|
33 |
|
34 | console.log('running...');
|
35 | program()
|
36 | .then(function (result) {
|
37 | console.log(result);
|
38 | })
|
39 | .catch(function(err) {
|
40 | console.log('----- rejected: -----');
|
41 | console.log(err);
|
42 | });
|