VimUnDo&/q\A%jL`ĒfOOOOPD#_Pc) consumer.next(null, consumer.state)5_Pdc5_Pdvar end = require()5_Pdvar end = require("")5_$P #%d& consumer.next(null, state.value)5_7P'68d% if (value === null) end(reducers)5_7P*68d$ if (value === end) end(reducers)5_ P/  dfunction end(consumers) {5_  P e d5_ P efunction Hub()5_ P efunction Hub() {}5_ P  f5_W$PWYh WYg5_XPWYh if ()5_XP WYh if (isArray())5_XPWYh if (isArray(hub))5_XPWYh if (isArray(source))5_XP1WYh if (isArray(source)) return 5_ XX v P: h5_ YY v P< 5_ XX v P< j i h5_ ZZ v PG j5_  [[ v PH kisArray = Array.isArray5_! [[[ v PQZ[$ if (isArray(source)) return source5_ "!Z[[ v PVZ\k Z\j5_!#"[\\ v P[Z\k return new Hub()5_"$#[\\ v P`[]k5_#%$]]_vPe\^l+ var value = convert(null, hub.accumulate) value[input] = source value[consumers] = []5_$&%\]]vPf[\5_%'&\\\vPf[\ 5_&('\\\vPg[\ return value5_')(\\vPmh g5_(*) __vPrk j5_)+* ``vPxkfunction Hub() {5_*,+``vPޅ+ var value = convert(null, hub.accumulate)5_+.,__vPދj this.input = source5_,/-. __vPޏj this[input = source5_.0/__vPޓ value[input] = source5_/10^^vPޔi value[consumers] = []5_021^^vPޙifunction Hub(source, ) {5_132]^^vPޡ\^i return new Hub(source, [])5_243aahvP޸` :hub.accumulate = function accumulate(hub, next, initial) {: // Enqueue new consumer into consumers array so that new$ // values will be delegated to it.5 hub[consumers].push({ next: next, state: initial })8 // If source is not in the process of consumption than // start it up. if (!isOpen(hub)) open(hub)}module.exports = hub5_354`aavP޹`ba5_465`bbvP޺`bc`bb5_576ccvPdc5_687llvPml5_798mmvPmaccumulate.define()5_8:9mmvPmaccumulate.define(Hub, func)5_9;:mmvPmaccumulate.define(Hub, )function accumulate(hub, next, initial) {m:hub.accumulate = function accumulate(hub, next, initial) {5_:<;llvPl}5_;=<llvP"var convert = require("./convert")5_<>=kkvP7k5_=?>WllvPGVWfunction isHub(value) {5_>@?WkkvPHVW9 return !value || (input in value && consumers in value)5_?A@WjjvPHVW}5_@BAWiivPIVW5_ACBdhhvPJcdhub.isHub = isHub5_BDCPD*g(var accumulate = require("./accumulate")5_CEDPD,g$var reduce = require("./accumulate")5_DGE*PD1g,var reduce = require("reducible/accumulate")5_EHFGPD6g"var reduced = require("./reduced")5_GIHPD;g'var isReduced = require("./is-reduced")5_HJIPDAgvar end = require("./end")5_IKJ PDvg@accumulate.define(Hub, function accumulate(hub, next, initial) {5_JLK&PDzg