close.js
667 Bytes
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
//var a = require('assertions')
var es = require('event-stream')
var MuxDemux = require('../')
var test = require('tape')
test('test close', function (a) {
var mx = MuxDemux(), ended = false, callback = false
mx.on('end', function () {
ended = true
})
mx.close(function () {
callback = true
}) //end the mx stream after the sub-streams close.
var A = mx.createStream()
var B = mx.createStream()
var C = mx.createStream()
a.equal(ended, false)
A.end()
B.end()
a.equal(ended, false)
a.equal(callback, false)
C.end()
process.nextTick(function () {
a.equal(ended, true)
a.equal(callback, true)
a.end()
})
})