| 1 |
|
| 2 |
|
| 3 | var sc = require('skale-engine').context();
|
| 4 |
|
| 5 | sc.parallelize([1, 2, 3, 4, 5, 6, 7, 8, 9]).
|
| 6 | intersection(sc.parallelize([5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15])).
|
| 7 | collect(function(err, res) {
|
| 8 | console.log(res);
|
| 9 | res.sort();
|
| 10 | console.assert(JSON.stringify(res) === JSON.stringify([5, 6, 7, 8, 9]));
|
| 11 | sc.end();
|
| 12 | });
|