VimUnDoߵNlO*+H_퀚Ɇ"N:PO_Oi5_Oifunction channel()5_Oifunction channel() {}5_Oifunction channel() {5_Oi5_Oivar 5_vOj  'use strict';var Method = require('method')5_  vOj function channel() {} }5_ vOj  5_ vOj  5_ vOj  var enqueue = Method()5_ vOj 5_  vOjG  5_  vOjJ function Channel()5_ vOjL function Channel() {}5_ vOjM 5_vOjPfunction channel() {}5_ vOjV function Channel() {} }5_ vOjW  5_vOj\  5_vOj_ var reduce = require()5_vOj_ var reduce = require('')5_vOjc var reduce = require('./core')5_vOjf reduce5_vOjk reduce.define()5_vOjq reduce.define(Channel, )5_!vOjs "reduce.define(Channel, function())5_#vOjs %reduce.define(Channel, function() {})5_ vOjv #reduce.define(Channel, function() {5_ vOj var end = Method()5_  vOj 5_! vOj  5_ "!vOj5_!#" vOjclose.define()5_"$# vOj!close.define(Channel, function())5_#%$"vOj$close.define(Channel, function() {})5_$&%vOj"close.define(Channel, function() {5_%'&vOjfunction Channel() {}5_&('vOj 5_')(vOj 5_(*)vOk this.5_)+*vOk this._result = 5_*,+ vOkN 5_+-, vOkQ  5_,.- vOkd 5_-/. vOkh 5_.0/ vOkj exports.enqueue5_/10 vOko  5_021vOku 5_132vOk} 5_243 vOk"!5_354vOk"function Channel() {5_465vOk")close.define(Channel, function(channel) {5_576vOk"4reduce.define(Channel, function(channel, f, start) {5_687vOk#"5_798vOk#enqueue.define()5_8:9 vOk#!enqueue.define(Queue, function())5_9;:"vOk#$enqueue.define(Queue, function() {})5_:<;vOk$"enqueue.define(Queue, function() {5_;=<$vOk$'enqueue.define(Queue, function(queue) {5_<>=)vOk$5_=?>vOk%5_>@?vOk5_?A@vOk%5_@BAvOk% if ()5_ACBvOk% if (!isClosed())5_BDCvOk% if (!isClosed(queue))5_CEDvOk% if (!isClosed(queue)) {}5_DFEvOk' &5_EGFvOk' queue.queued.push()5_FHGvOk' queue.queued.push(values)5_GIHvOk' queue.queued.push(value)5_HJI vOk' queue.queued.push(item)5_IKJ vOk( '5_JLKvOk( this._queued = []5_KMLvOk) (5_LNM vOl) react()5_MONvOl!* !)5_NPO!vOl!#+!#*5_OQP"vOl!"e5_PRQ!vOl# "+})!#+!#*5_QSR"vOl)"$+ "$*5_RTS#vOl+"$+ if ()5_SUTvOl.,+5_TVUvOl8,isClosed.define()5_UWV!vOl:,"isClosed.define(Queue, function())5_VXW#vOl:,%isClosed.define(Queue, function() {})5_WYXvOl;-5_XZY vOl@.#isClosed.define(Queue, function() {5_Y[Z$vOlA/ .5_Z\[ vOlG/ return queue.result5_[]\vOlV0/5_\^] vOlZ0close.define()5_]_^vOl^0close.define(Queue, function())5_^`_ vOl^ 0"close.define(Queue, function() {})5__a`vOla1 close.define(Queue, function() {5_`ba#vOlc1&close.define(Queue, function(buffer) {5_acb!vOle 2  15_bdcvOlf 2 if ()5_cedvOli 2 if (!isClosed())5_dfevOlj 2 if (!isClosed(queue))5_egfvOlk!2 if (!isClosed(queue)) {}5_fhgvOll!4 !35_gih vOl!4 var values = is()5_hji *vOl"4* var values = is(queue._state, reduced)5_ikj ,vOl"5, var values = is(queue._state, reduced) ?5_jlk!8vOm !#7+ !#65_kml" vOm !#7 realize()5_lnm"!vOm'!#7" realize(queue._result, values)5_mon vOm-!7? var values = is(queue._state, reduced) ? queue._state.value5_npo#vOm9"$7 5_oqp#'vOmN"$75 queue._next = queue._state = queue.result = queue5_prq#6vOmO"$76 queue._next = queue._state = queue._result = queue5_qsr$vOm\$&8 $&75_rtsvOm85_sutvOm9 this._result = false;5_tvuvOm9 this._closed = false;5_uwvvOm this._closed = false5_vxwvOm9 85_wyxvOm9 this._queued = [];5_xzyvOm: 95_y{z1vOm01'close.define(Queue, function(channel) {5_z|{1vOm01 if (is)5_{}|1vOm01})5_|~}vOmvar react = Method875_}~vOm9var react = Method()5_~+vOn+-;+-:5_, vOn+-;react.define()5_,vOn +-;react.define(Queue, function())5_, vOn!+.;"react.define(Queue, function() {})5_,vOn#+-< react.define(Queue, function() {5_,!vOn&,.= ,.<5_-/vOn3-/> -/=5_. vOn6-/> while ()5_.vOn:-/> while (queued.length)5_.vOn@.0? .0>5_/vOnK.0? queue._state = next()5_/3vOnU/1@ /1?5_0vOn]/1@ if ()5_0 vOn_/1@ if (is())5_0vOne/1@ if (is(queued.state))5_0vOnf/1@ if (is(queued._state))5_0#vOnl/1@# if (is(queued._state, reduced))5_0$vOnp/2@* if (is(queued._state, reduced)) return5_1 vOnr02A return5_1vOnv02A return close()5_.vOn{-/A while (queued.length && next)5_."vOn|-/A" while (queued.length && next) {}5_1vOn}13B 13A5_< vOn<>C <>B5_=vOn<>C if ()5_=vOn<>C if (isClosed())5_=vOn<>C if (isClosed(queue))5_<%vOn;=C2reduce.define(Queue, function(channel, f, start) {5_="vOn=?D =?C5_>vOn>@E >@D5_?vOn?AF ?AE5_@vOn?AF react()5_?vOn>@F queue._next = next5_@ vOn@BG @BF5_vOnG this._queued = [] this._result = defer() this._state = null this._next = null5_vOn 5_vOn5_vOnBfunction Queue() {}B}5_.&vOn-.5_=&vOn=BA =?@5_>&vOn=?D this._queued = []5_>&vOn=?D this._queued = slice()5_=&vOn<>Dfunction channel() {5_= &vOo=?E =?D5_?&vOo >@E! this._queued = slice(arguments)5_@&vOo ?AE this._result = defer()5_A&vOo@BE this._state = null5_B&vOoACE this._next = null5_B&vOoBDF BDE5_D&vOoDFGDFF5_&vOAvar eventuals = requireHG5_&vOJIvar eventuals = require()5_&vOJIvar eventuals = require('')5_'&vOUI)var eventuals = require('eventuals/core')5_"&vOXI-var eventuals = require('eventuals/eventual')5_,&vOY I,var eventuals = require('eventual/eventual')5_&vOmKJ5_&vOrKvar Name = require()5_&vOtKvar Name = require('')5_&vOvKvar Name = require('name')5_&vOw Kvar Name = require('name');5_&vOzvar Name = require('name')5_&vO{var Met5_ &vO| K J5_ &vO Kvar Name = require()5_ &vO Kvar Name = require('')5_ &vO Kvar Name = require('')5_ vOK-var eventuals = require('eventual/eventual'),7 defer = eventuals.defer, deliver = eventual.delivervar Name = require('name')5_ vO I H5_ /vO L7 defer = eventuals.defer, deliver = eventual.deliver5_& vO%'L! realize(queue._result, value)5_vOML5_%vO$&M> var value = is(queue._state, reduced) ? queue._state.value5_%vO$&M= var value = is(queue[state, reduced) ? queue._state.value5_%2vO$&M> var value = is(queue[state], reduced) ? queue._state.value5_%8vO$&M> var value = is(queue[state], reduced) ? queue.[state.value5_&4vO%'M9 : queue._state5_&8vO%'M8 : queue[state5_%2vO$&M? var value = is(queue[state], reduced) ? queue.[state].value5_$vO$&N $&M5_%vO$&N var state 5_%vO$&N var data = queue[]5_% vO$&N var data = queue[state]5_&vO%'N> var value = is(queue[state], reduced) ? queue[state].value5_&1vO %'N7 var value = is(value, reduced) ? queue[state].value5_'+vO&(N9 : queue[state]5_'1vO&(N1 : queue[state]5_& vO%'N0 var value = is(value, reduced) ? value.value5_&vO %'N1 var result = is(value, reduced) ? value.value5_& vO#%'N- result = is(value, reduced) ? value.value5_'#vO&%'N, value = is(value, reduced) ? value.value: value&(N* : value5_vO*NM5_(vO8')N! deliver(queue._result, value)5_(vO:')N deliver(queue[result, value)5_vOA O N5_vOE Ovar next = Name()5_vOF Ovar next = Name(0)5_* vOI)+OE queue._next = queue._state = queue._result = queue._queued = null5_*vOJ)+OD queue[next = queue._state = queue._result = queue._queued = null5_*vOL)+OE queue[next] = queue._state = queue._result = queue._queued = null5_*vON)+OD queue[next] = queue[state = queue._result = queue._queued = null5_*(vOP)+OE queue[next] = queue[state] = queue._result = queue._queued = null5_*-vOR)+OD queue[next] = queue[state] = queue[result = queue._queued = null5_*7vOT)+OE queue[next] = queue[state] = queue[result] = queue._queued = null5_*=vOV)+OD queue[next] = queue[state] = queue[result] = queue[queued = null5_*<*7v7OZ!P!O5_0+<+7v7Od/1P0 var queued = queue._queued, next = queue._next5_0+<+7v7Of/1P/ var queued = queue[queued, next = queue._next5_0,+<+7v7Oi/1P0 var queued = queue[queued], next = queue._next5_0/+<+7v7Ok/1P/ var queued = queue[queued], next = queue[next5_0"+<+7v7Om/1P0 var queued = queue[queued], next = queue[next]5_0 +<+7v7Op/1P- var queued = queue[queued], f = queue[next]5_1+<+7v7Os02P! while (queued.length && next) {5_1 +<+7v7Ov02P# while (messages.length && next) {5_0+<+7v7O{/1P/ var messages = queue[queued], f = queue[next]5_10 0vO02P while (messages.length && f) {5_2 0 0vO13P5 queue._state = next(queue._state, queued.shift())5_20 0vO13P4 queue[state = next(queue._state, queued.shift())5_20 0vO13P5 queue[state] = next(queue._state, queued.shift())5_20 0vO13P2 queue[state] = f(queue._state, queued.shift())5_2 0 0vO13P1 queue[state] = f(queue[state, queued.shift())5_2)0 0vO13P2 queue[state] = f(queue[state], queued.shift())5_30 0vO24P# if (is(queued._state, reduced))5_30 0vO24P" if (is(queued[state, reduced))5_9 0 0vO8:P queue._queued.push(item)5_90 0vO8:P queue[queued.push(item)5_@ 0 0vO?AP queue._state = start5_@ 0 0vO?AP queue[state = start5_A 0 0vO@BP queue._next = f5_A 0 0vO@BP queue[next = f5_C0 0vOBDP return queue._result5_C0 0vOBDP return queue[result5_H 0 0vOGIP# result._queued = slice(arguments)5_H0 0vOGIP" result[queued = slice(arguments)5_I 0 0vOHJP result._result = defer()5_I0 0vOHJP result[result = defer()5_ J 0 0vOIKP result._state = null5_  J0 0vOIKP result[state = null5_   K 0 0vOJLP result._next = null5_   K 0 0vOJLP result[next = null5_   P0 0vOOP5_  O0 0vONO5_  0 0vO O N5_4 4vO5_3 3vO5_ &vOPI var = require('eventuals/core')5