VimUnDo2pŚ;~YG-[%"0xE " return hub(signal())UUUUP _!P !var signal = require('./signal'),5_ P  var emit 5_ P , emit = signal.emit, close = signal.close5_Pchannel.enqueue = emit5_Pchannel.close = close5_PI'/* vim:set ts=2 sw=2 sts=2 expandtab */5_PIM/*jshint asi: true undef: true es5: true node: true browser: true devel: true5_  PI9 forin: true latedef: false globalstrict: true */5_ PI5_ PI 'use strict';5_  PI "use strict';5_ PIvar hub = require('./hub')5_  PIvar hub = require("./hub')5_ PI var signal = require('./signal')5_PI var signal = require("./signal')5_P5_Pfunction Channel()5_Pfunction Channel() {}5_Pfunction Channel() {5_P 5_P 5_ P this.input = input5_P this.source = input5_ P  this.source = 5_P this.signal = 5_P   5_P  this.input = hub()5_P  this.input = hub(this())5_P!  this.input = hub(this.signals)5_P$function Channel(input) {5_ P'function Channel(input) {5_! P) this.signal = signal()5_ "!P,  this.input = hub(this.signal)5_!#"P/  this.input = hub(signals)5_"$#P15_#%$P8var accumulate = require()5_$&%P8var accumulate = require("")5_%'&'vP<5_&('&'vP>(var accumulate = require("./accumulate")5_')('vP@5_(*)'vPDvar close = require()5_)+*'vPEvar close = require("")5_*,+'vPI"var accumulate = require("./emit")5_+-, 'vPN  5_,.- 'vPS accumulate.define()5_-/. 6'vP[ 8accumulate.define(Channel, function accumulateChannel())5_.0/ M'vPa Naccumulate.define(Channel, function accumulateChannel(channel, next, initial))5_/10 O'vPb Qaccumulate.define(Channel, function accumulateChannel(channel, next, initial) {})5_021 O'vPc Qaccumulate.define(Channel, function accumulateChannel(channel, next, initial) {})5_132'vPe  })5_243'vPf  })5_354 'vPg   5_485 'vPl  accumulate()5_5968'vP  accumulate(channel.input, )5_8:9&'vP ' accumulate(channel.input, function())5_9;:('vP * accumulate(channel.input, function() {})5_:<;('vP ( accumulate(channel.input, function() {5_;=<'vP })5_<>='vP5_=?>'vPaccumulate.define()5_>@? 'vP$accumulate.define(Channel, function)5_?A@'vPemit.define(Channel, function)5_@BA*'vP+emit.define(Channel, function emitChannel()5_ACB8'vP8emit.define(Channel, function emitChannel(channel, data)5_BDC:'vP;emit.define(Channel, function emitChannel(channel, data) {}5_CED'vP}5_DFE'vP5_EGF 'vP emit.define()5_FHG'vPemit.define(Channel, )5_GIH'vPclose.define(Channel, )5_HJI'vP!close.define(Channel, function())5_IKJ.'vP.close.define(Channel, function closeChannel())5_JLK,'vP-close.define(Channel, function closeChannel()5_KML:'vP:close.define(Channel, function closeChannel(channel, data)5_LNM<'vP=close.define(Channel, function closeChannel(channel, data) {}5_MON'vP }5_NPO'vP!  5_OQP'vP! emit()5_PRQ'vP! emit(channel.input, data)5_QSRvP" !5_RTSvP " emit(channel.signal, data)5_SUTvP  " return hub(signal())5_TUvP  " return new Channel()5_5786 'vPy  this.source = hub(signal)5_67'vP|  accumulate(channel.sou, )5