VimUnDo8%9D K\D甛=54 A5 $$$$PM _89vP9!var test = require("./util/test")5_ vP9!var lazy = require("./util/lazy")5_ vP95_ vP :!var concat = require("../concat")5_  vP :var into = require("../into")5_  vP :!var signal = require("../signal")5_ vP;:5_   vP;!var signal = require("../signal")5_  vP; var event = require("../signal")5_ vP;var pipe = require("../pipe")var event = require("../event")'var concat = require("reducers/concat")5_ vP985_  vP5_   vP<;5_  vP<var send = require()5_ vP<var send = require("")5_  vP 5_  vP var emit = require("../emit")5_  vP :var cache = require("../cache")5_  vP :var cache = require("cache")5_  vP :5_  vP ;5_vP<var delay = require("../delay")#var flatten = require("../flatten")5_ vP 95_ vP <var delay = require("../delay")5_4vP35<1 pipe(flatten([[1, 2, 3], [4, 5], [ 6, 7 ]]), s)5_ vP <#var flatten = require("../flatten")5_ vP <!var merge = require("../flatten")5_ vP  <var merge = require("../merge")5_vP 02 var s = signal()%' var s = signal() var s = signal() var s = signal()5_vPJ>exports["test pipe stream into not open"] = function(assert) {5_ vPJ var s = event()5_! vPK assert.throws(function() {5_ "!vPK pipe([ 1, 2, 3 ], s)5_!#"vPK }, "can't pipe if can't emit")5_"$#vPL}5_#$vPL 5