VimUnDol^S~ $G8J╥NG }, function() {uuuuP5_P)5_P,Eexports["test hub open / close propagate"] = function(assert, done) {5_ P/R"use strict";exports["test hub open / close propagate"] = function(assert, done) {5_Px5_Pbvar hub = require5_Pivar hub = require()5_Pivar hub = require("")5_ Pp5_ P5_ P5_ P 5_  P  var s = signal()3 assert.ok(signal.isClosed(c), "signal is closed")z| var c = signal()kmI assert.ok(signal.isClosed(c), "signal is closed once consumer is done")Y[ var c = signal()PRI assert.ok(signal.isClosed(c), "signal is closed once consumer is done")GI var c = signal()"$ var c = signal()0 assert.ok(signal.isClosed(c), "signal closed")N assert.ok(!signal.isClosed(c), "signal is not closed until close is called")F assert.ok(signal.isOpen(c), "signal is open after reduce is called")8 assert.ok(!signal.isClosed(c), "signal is not closed") 4 assert.ok(!signal.isOpen(c), "signal is not open")  var c = signal()5_ P  5_ P var map = require()5_ P  var map = require("")5_ P  5_ P var into = require()5_ P  var into = require("")5_P  emit(s, end) emit(s, 3) emit(s, 2) emit(s, 1)km emit(c, 4)jl emit(c, 3)ik emit(c, 2)eg emit(c, 1)PR emit(c, 2)OQ emit(c, 1)@BC "gets no messages if no messages emitd")02 emit(c, 3)/1 emit(c, 2)+- emit(c, 1) emit(c, 2) emit(c, 1)5_P var end = require 5_P var end = require()5_P var end = require("")5_ P var when = require  5_P var when = require()5_P var when = require("")5_ P  5_ P var take = require()5_ P var take = require("")5_ P   5_ P var concat = require()5_! P var concat = require("")5_ "!P  5_!$"P!5_"%#$   vP6  var map = require("reduces/map")5_$&%   vP8 "var into = require("reduces/into")5_%'&vP9 #var take = require("reducers/take")5_&('vP:'var concat = require("reducers/concat")5_')(vPC5_(*)vPj 5_)+*vPl var h = hub(c)5_*,+vPt 5_+-,vPu5_,.-vP|2 assert.ok(!event.isOpen(c), "event is not open")5_-/.vP& assert.equal(), "event is not open")5_.0/vP/ assert.equal(called, 0), "event is not open")5_/10vP6 assert.ok(!event.isClosed(c), "event is not closed")5_021 .vP # "5_132!.vP ". assert.equal(called, 0, "event is not open")5_243!(.vP ". assert.equal(called, 1, "event is not open")5_354".vP!"5_465".vP!"D assert.ok(event.isOpen(c), "event is open after reduce is called")5_576".vP!"L assert.ok(!event.isClosed(c), "event is not closed until close is called")5_687%.vP$& close(c, 3)5_798%.vP%' %'5_8:9&.vP%' send()5_9;:(.vP'(. assert.ok(event.isClosed(c), "event closed")5_:<;(.vP'(5_;=<?.vP>@ close(c)5_<>=?.vP>@ send(c)5_=?>.vP close(c, 0)5_>@?.vP 5_?A@.vP  send()5_@BA.vP! var c = event()5_ACB#.vP"$ send(c, 1)5_BDC$.vP#% send(c, 2)5_CED%.vP$& send(c, 3)5_DFE&.vP"%' send(c, end)5_EGF].vP@\]G assert.ok(event.isClosed(c), "event is closed once consumer is done")5_FHG].vPA#\]5_GIHv.vPBuvG assert.ok(event.isClosed(c), "event is closed once consumer is done")5_HJIv.vPC$uv5_IKJt.vPHtv tv5_JLKu.vPJ%tv send()5_KML.vPN&1 assert.ok(event.isClosed(c), "event is closed")5_LNM-.vP_-/-/5_MON.vPb'5_NPO).vPq((*F assert.deepEqual(actual, [ 1, 2, 3 ], "all value were propagated")5_OQP.vP5_PRQ.vPvar for5_QSR.vPvar fold = require()5_RTS.vP)var fold = require("")5_SUT"vP#var fold = require("reducers/fold")5_TVU"vP*5_UWV"vPO+#var fold = require("reducers/fold")5_VXW/"vPU,.//*5_WYX"vP\-*/5_XZY"vPj var c = event()5_Y[Z"vPl send(c, 0)5_Z\["vPm. send(c, end)5_[]\"vPq0 var h = hub(c)5_\^]"vP })5_]_^"vP }, function())5_^`_"vP }, function() {})5__a`"vP1 5_`ba"vP 5_acb "vP done()5_bdc "vP done(0)5_ced"vP console.log()5_dfe"vP assert.fail()5_egf"vP2 assert.fail("")5_fhg"vP assert.fail("foo")5_gih"vP assert.fail(Error()"foo")5_hji"vP3 assert.fail(Error("foo")5_ikj"vPB assert.deepEqual(actual, [], "after close reduces to empty")5_jlk"vP done()5_kml"vP when(p2, function(actual) {5_lnm"vP when(p2, null5_mon"vP when(p2, null,, function() { }, function() {5_npo"vP assert.fail(Error("foo"))5_oqp"vP assert.pass(Error("foo"))5_prq"vP assert.pass(""5_qsr3"vP43 assert.pass("event can be consumed only once"5_rts"vP4 assert.pass("event can be consumed only once")5_sut8"vP: assert.pass("event erros can be consumed only once")5_tu5"vP58 assert.pass("event erros when reduced after it''")5_"$#   vP3 var hub = require("/hub")5_ Pwvar send = require("./send")5