1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
| var es = require('../')
| , it = require('it-is').style('colour')
| , d = require('ubelt')
|
| function makeExamplePipe() {
|
| return es.connect(
| es.map(function (data, callback) {
| callback(null, data * 2)
| }),
| es.map(function (data, callback) {
| d.delay(callback)(null, data)
| }),
| es.map(function (data, callback) {
| callback(null, data + 2)
| }))
| }
|
| exports['simple pipe'] = function (test) {
|
| var pipe = makeExamplePipe()
|
| pipe.on('data', function (data) {
| it(data).equal(18)
| test.done()
| })
|
| pipe.write(8)
|
| }
|
| exports['read array then map'] = function (test) {
|
| var readThis = d.map(3, 6, 100, d.id) //array of multiples of 3 < 100
| , first = es.readArray(readThis)
| , read = []
| , pipe =
| es.connect(
| first,
| es.map(function (data, callback) {
| callback(null, {data: data})
| }),
| es.map(function (data, callback) {
| callback(null, {data: data})
| }),
| es.writeArray(function (err, array) {
| it(array).deepEqual(d.map(readThis, function (data) {
| return {data: {data: data}}
| }))
| test.done()
| })
| )
| }
|
| exports ['connect returns a stream'] = function (test) {
|
| var rw =
| es.connect(
| es.map(function (data, callback) {
| callback(null, data * 2)
| }),
| es.map(function (data, callback) {
| callback(null, data * 5)
| })
| )
|
| it(rw).has({readable: true, writable: true})
|
| var array = [190, 24, 6, 7, 40, 57, 4, 6]
| , _array = []
| , c =
| es.connect(
| es.readArray(array),
| rw,
| es.log('after rw:'),
| es.writeArray(function (err, _array) {
| it(_array).deepEqual(array.map(function (e) { return e * 10 }))
| test.done()
| })
| )
|
| }
|
|
| require('./helper')(module)
|
|
