Blame view
node_modules/mux-demux/test/pause.js
407 Bytes
f7563de62
|
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 |
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() }) |