pause.js
407 Bytes
var MuxDemux = require("..")
//var assert = require("assert")
require('tape')('pause', function (t) {
var mdm1 = MuxDemux()
var mdm2 = MuxDemux()
var called = false
mdm2.on("connection", function (stream) {
t.equal(stream.meta, "foo")
called = true
})
mdm1.pause()
mdm1.createStream("foo")
mdm1.pipe(mdm2).pipe(mdm1)
mdm1.resume()
t.equal(called, true)
t.end()
})