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
|
| var es = require('../')
| , it = require('it-is')
| , d = require('ubelt')
|
| exports ['gate buffers when shut'] = function (test) {
|
| var hundy = d.map(1,100, d.id)
| , gate = es.pause()
| , ten = 10
| es.connect(
| es.readArray(hundy),
| es.log('after readArray'),
| gate,
| //es.log('after gate'),
| es.map(function (num, next) {
| //stick a map in here to check that gate never emits when open
| it(gate.paused).equal(false)
| console.log('data', num)
| if(!--ten) {
| console.log('PAUSE')
| gate.pause()//.resume()
| d.delay(gate.resume.bind(gate), 10)()
| ten = 10
| }
|
| next(null, num)
| }),
| es.writeArray(function (err, array) { //just realized that I should remove the error param. errors will be emitted
| console.log('eonuhoenuoecbulc')
| it(array).deepEqual(hundy)
| test.done()
| })
| )
|
| gate.resume()
|
| }
| require('./helper')(module)
|
|
