VimŸUnDoå›Ôê½?M™áŒKÚŠ±¼:~)˜ ÙS<üûÃÜhŠ3ù. &È°é°°P®$4_ÐÉÈ6"ÿÿÿÿ66vO·¹}aõ57b%function process(reducer, result, ) {5_ÐÈÊÉ7ÿÿÿÿ66vO·¹ƒõ79c õ79b5_ÐÉËÊ8ÿÿÿÿ66vO·¹Œõ8:d õ8:c5_ÐÊÌË8ÿÿÿÿ66vO·¹–õ79d queue.shift()5_ÐËÍÌ6ÿÿÿÿ66vO·¹šõ57d*function process(reducer, result, queue) {5_ÐÌÎÍ8ÿÿÿÿ66vO·¹õ79d var queue.shift()5_ÐÍÏÎ9ÿÿÿÿ66vO·¹¬õ8:d realize()5_ÐÎÐÏ:ÿÿÿÿ66vO·¹Ãõ:<e õ:<d5_ÐÏÑÐ;ÿÿÿÿ66vO·¹Ècõ:<e return results5_ÐÐÒÑAÿÿÿÿ66vO·¹ÔõACf õACe5_ÐÑÓÒBÿÿÿÿ66vO·¹ÝõACf var reducer = queue[]5_ÐÒÙÓB#ÿÿÿÿ66vO·¹àõACf$ var reducer = queue.reducers[]5_ÐÓÚÔÙBÿÿÿÿ66vO·¹ùõAB% var reducer = queue.reducers[0]5_ÐÙÛÚDÿÿÿÿ66vO·¹úõCD! var results = queue.results5_ÐÚÜÛDÿÿÿÿ66vO·¹údõCD% var eventuals = queue.eventuals5_ÐÛÝÜDÿÿÿÿ66vO·ºõDFd õDFc5_ÐÜÞÝEÿÿÿÿ66vO·ºõDFd var reducer = reducers[]5_ÐÝßÞF#ÿÿÿÿ66vO·ºõEGd@ var result = go(reducers[0], results[0], queued.shift())5_ÐÞàßF0ÿÿÿÿ66vO·ºõEGdA var result = go(reducer.next, results[0], queued.shift())5_ÐßáàF3ÿÿÿÿ66vO·ºõEGdD var result = go(reducer.next, reducer.start, queued.shift())5_ÐàâáFÿÿÿÿ66vO·º1õFHe õFHd5_ÐáãâGÿÿÿÿFCFvO·ºCõFHe process()5_ÐâäãGÿÿÿÿFCFvO·ºKõFHe! reducer.state = process()5_ÐãåäG$ÿÿÿÿFCFvO·ºLõFHe$ reducer.state = go(process()5_ÐäæåHÿÿÿÿFCFvO·ºWõGH1 results[0] = go(function(value, result) {5_ÐåçæH ÿÿÿÿFCFvO·ºXõGH if (value === end) {5_ÐæèçHÿÿÿÿFCFvO·ºYõGH reducers.shift()5_ÐçéèHÿÿÿÿFCFvO·ºZõGH results.shift()5_ÐèêéHÿÿÿÿFCFvO·ºZõGH. realize(eventuals.shift(), result)5_ÐéëêH ÿÿÿÿFCFvO·ºZõGH }5_ÐêìëH ÿÿÿÿFCFvO·º[õGH return value5_ÐëíìHÿÿÿÿFCFvO·º[õGH }, result, results[0])5_ÐìîíG+ÿÿÿÿFCFvO·ºifõFH]3 reducer.state = go(process, results, queue)5_ÐíïîFÿÿÿÿFCFvO·ºÑõEG]D var result = go(reducer.next, reducer.state, queued.shift())5_ÐîðïF#ÿÿÿÿFCFvO·ºÔõEG]A var result = reducer.next, reducer.state, queued.shift())5_ÐïñðF7ÿÿÿÿFCFvO·ºæõFH^ õFH]5_ÐðòñGÿÿÿÿFCFvO·ºçõFH^ if ()5_ÐñóòGÿÿÿÿFCFvO·ºèõFH^ if (is())5_ÐòôóGÿÿÿÿFCFvO·ºêõFH^ if (is(result))5_ÐóõôGÿÿÿÿFCFvO·ºñõFH^ if (is(result, reduced)5_ÐôöõG"ÿÿÿÿFCFvO·ºòõFI^# if (is(result, reduced)) {}5_Ðõ÷öGÿÿÿÿFCFvO·ºõõGI` õGI_5_Ðöø÷HÿÿÿÿFCFvO·»gõGI` reducer.shift()5_Ð÷ùøHÿÿÿÿFCFvO·» õHJa õHJ`5_ÐøûùIÿÿÿÿFCFvO·»õHJa realize()5_ÐùüúûI ÿÿÿÿFCFvO·».hõHJa! realize(reducer.result)5_ÐûýüJ ÿÿÿÿFCFvO·»CõIKa }5_ÐüþýJÿÿÿÿFCFvO·»IõILa } else {}5_ÐýÿþLÿÿÿÿLLvO·»LõKMb2 reducer.state = go(process, result, queue)5_ÐþÿJÿÿÿÿLLvO·»MõJLc õJLb5_ÐÿKÿÿÿÿMMvO·»NõJLc reducer.state5_ÐM ÿÿÿÿMMvO·»PõLM% = go(process, result, queue)5_ÐKÿÿÿÿMMvO·»SõJLb reducer.state = 5_ÐK!ÿÿÿÿMMvO·»TjõJLb! reducer.state = results5_Ð6ÿÿÿÿMMvO·»\õ56!function process(result, queue) {5_Ð6ÿÿÿÿLLvO·»]õ56 if (is(result, reduced)) {5_Ð6ÿÿÿÿKKvO·»]õ56 var reducer = queue.shift()5_Ð6ÿÿÿÿJJvO·»]õ56) realize(reducer.result, result.value)5_Ð 6ÿÿÿÿIIvO·»^õ56 }5_Ð 6ÿÿÿÿHHvO·»^õ56 return result5_Ð 6ÿÿÿÿGGvO·»_õ56}5_Ð 6ÿÿÿÿFFvO·»_lõ565_Ð Q:ÿÿÿÿ vO·¾&õPRZF queue.reducers.push({ next: f, state: start, results: promise })5_Ð Q9ÿÿÿÿ vO·¾'mõPRZE queue.reducers.push({ next: f, state: start, result: promise })5_Ð A ÿÿÿÿ vO·¾.nõ@BZ/ realize(reducer.result, result.value)5_ÐW2ÿÿÿÿ vO·¿WõVXZ5function queue() { return new Queue([], [], [], []) }5_ÐWÿÿÿÿ vO·¿ZõVYZ-function queue() { return new Queue([], []) }5_ÐXÿÿÿÿ vO·¿]õWZ[ return new Queue([], []) }5_ÐXÿÿÿÿ vO·¿_õWY\ return new Queue([], [])5_ÐXÿÿÿÿ vO·¿‘õWY] var value = Queue([], [])õXZ] õXZ\5_Ðÿÿÿÿ vO·¿¦õ]õ\5_Ðÿÿÿÿ! !vO·¿©õ var undef5_Ðÿÿÿÿ vO·¿ªoõ5_Ð$ÿÿÿÿ vO·¿³põ$)]õ$&\5_Ð\ÿÿÿÿ vO·¿¹õ[]` var value = Queue([], [])5_Ð\ÿÿÿÿ vO·¿½õ[]`" var value = Queue(slice()[], [])5_Ð\ÿÿÿÿ vO·¿¿qõ[]`! var value = Queue(slice([], [])5_Ð\ÿÿÿÿ vO·¿ârõ[]`" var value = Queue(slice([]), [])5_Ð\ÿÿÿÿ vO·¿èsõ[]`) var value = Queue(slice(arguments), [])5_Ð\ÿÿÿÿ vO·¿êõ\^`5_Ð]ÿÿÿÿ vO·¿ítõ\]5_Ð \ ÿÿÿÿ vO·¿ïuõ[]`- var value = new Queue(slice(arguments), [])5_Ð! 0ÿÿÿÿ vO·ÀYõ13var Closeable = protocolõ03aõ02`5_Ð "!2ÿÿÿÿ vO·Àcõ13bvar Closeable = protocol()5_Ð!#"2ÿÿÿÿ vO·Àcõ14bvar Closeable = protocol({})5_Ð"$#2ÿÿÿÿ vO·Àdõ24d õ24c5_Ð#%$3 ÿÿÿÿ vO·Àhvõ24d close: []5_Ð$&%4ÿÿÿÿ vO·Àpõ46eõ46d5_Ð%'&5ÿÿÿÿ vO·Àuõ46eexports.5_Ð&('4ÿÿÿÿ vO·Àyõ46fõ46e5_Ð')(6ÿÿÿÿ vO·Àwõ68gõ68f5_Ð(*)2 ÿÿÿÿ vO·Áõ13gvar Closeable = protocol({5_Ð)+*2ÿÿÿÿ vO·Á õ13gvar End = protocol({5_Ð*,+3ÿÿÿÿ vO·Á%õ24g close: [ protocol ]5_Ð+-,2 ÿÿÿÿ vO·Á=õ13gvar Finite = protocol({5_Ð,.-2 ÿÿÿÿ22vO·Álõ13gvar Drainable = protocol({5_Ð-/.2ÿÿÿÿ22vO·Áoõ13gvar End = protocol({5_Ð.0/2ÿÿÿÿ22vO·Áwõ13gvar End = protocol({5_Ð/105ÿÿÿÿ22 v O·Á}õ46gvar close = Closeable.close5_Ð0215ÿÿÿÿ22 v O·Á~õ46gvar close = Endable.close5_Ð1325 ÿÿÿÿ22 v O·Áƒõ46gvar close = Endable.end5_Ð2436 ÿÿÿÿ22 v O·Á…õ57gexports.close = close5_Ð3546ÿÿÿÿ22 v O·Á†õ57gexports.end = close5_Ð4657ÿÿÿÿ22 v O·Áˆõ68gexports.Closeable = Closeable5_Ð5767ÿÿÿÿ22 v O·Á‰xõ68gexports.Endable = Closeable5_Ð687Rÿÿÿÿ22 v O·ÁšõRTh õRTg5_Ð798Sÿÿÿÿ22 v O·ÁžõRUh Endable, {}5_Ð8:9Sÿÿÿÿ22 v O·ÁŸõSUj õSUi5_Ð9;:Tÿÿÿÿ22 v O·Á¡õSUj end5_Ð:<;Tÿÿÿÿ22 v O·Á¤õSUj end: function()5_Ð;=<Tÿÿÿÿ22 v O·Á¦õSUj end: function end()5_Ð<>=Tÿÿÿÿ22 v O·Á§õSUj end: function end(queue)5_Ð=?>Tÿÿÿÿ22 v O·Á¨õSVj end: function end(queue) {}5_Ð>@?Uÿÿÿÿ22 v O·Á©õTVk }5_Ð?A@Vÿÿÿÿ22 v O·ÁõUWk }5_Ð@BAVÿÿÿÿ22 v O·ÁõUWk },5_ÐACBWÿÿÿÿWcvO·Á²õVXk Enqueueable, {, enqueue: function enqueue(queue, item) { queue.queued.push(item) react(queue) } }, Reducible, {. reduce: function reduce(f, queue, start) { var promise = defer()F queue.reducers.push({ next: f, state: start, promise: promise }) react(queue)" return go(identity, promise) }5_ÐBDCWÿÿÿÿWWvO·Á´õVW 5_ÐCEDWÿÿÿÿWWvO·Á·õUW^ })õVX^ })5_ÐDFEBÿÿÿÿVV vO·ÁºõBP^ õBD]5_ÐEGFOÿÿÿÿcc vO·ÁÀyõOQk õOQj5_ÐFHGNÿÿÿÿdd vO·ÁÍõMOk" return go(identity, promise)5_ÐGIHNÿÿÿÿdd vO·ÁÏzõMOk return promise)5_ÐHJIb ÿÿÿÿdd vO·Áàõbdl õbdk5_ÐIKJcÿÿÿÿee vO·Áæõbdl while ()5_ÐJLKcÿÿÿÿee vO·Áùõbdl queue.queued.splice()5_ÐKMLcÿÿÿÿee vO·Áùõcem õcel5_ÐLNMd ÿÿÿÿff vO·Áþõcem while ()5_ÐMONcÿÿÿÿff vO·Âõcen õcem5_ÐNPOeÿÿÿÿgg vO·Â õdfn while (reducers)5_ÐOQPeÿÿÿÿgg vO·Âõdfn while (reducers.length)5_ÐPRQeÿÿÿÿgg vO·Â õdgn while (reducers.length) {}5_ÐQSReÿÿÿÿhh vO·Âõegp õego5_ÐRTSfÿÿÿÿii vO·Âõegp reducers.shift()5_ÐSUTfÿÿÿÿii vO·Âõegp" reducer = reducers.shift()5_ÐTVUfÿÿÿÿii vO·Âõfhq õfhp5_ÐUWVgÿÿÿÿjj vO·Â"õfhq realize()5_ÐVXWgÿÿÿÿjj vO·Â$õfhq realize(reducers)5_ÐWYXgÿÿÿÿjj vO·Â2õfhq realize(reducer.promise)5_ÐXZYg.ÿÿÿÿjj vO·Â8{õfhq/ realize(reducer.promise, reducer.start)5_ÐY[ZD ÿÿÿÿjj vO·ÂÈõDFr õDFq5_ÐZ\[E ÿÿÿÿkk vO·ÂÊõDFr if ()5_Ð[j\Eÿÿÿÿkk vO·ÂÍ|õDFr if (queue)5_Ð\k^j2ÿÿÿÿkk vO·Ã<õ24s õ24r5_Ðjlk3 ÿÿÿÿll vO·ÃBõ24s ended: []5_Ðkml3ÿÿÿÿll vO·ÃF~õ24s ended: [ protocol ]5_Ðlnmdÿÿÿÿll vO·Ã`õdfs5_Ðmoneÿÿÿÿmm vO·Ãaõde5_Ðnpocÿÿÿÿll vO·Ãbõcet õces5_Ðoqpdÿÿÿÿmm vO·Ãgõcet ended: function ended()5_Ðprqdÿÿÿÿmm vO·Ãhõcft ended: function ended() {}5_Ðqsreÿÿÿÿnn vO·Ãiõdfu }5_ÐrtsC ÿÿÿÿnn vO·ÃoõBDu# record, [ 'queued', 'reducers' ],5_ÐsutC#ÿÿÿÿnn vO·Ãq€õBDu' record, [ 'queued', 'reducers', '' ],5_Ðtvudÿÿÿÿnn vO·Ãvõdfv õdfu5_Ðuwvdÿÿÿÿoo vO·Ã~õcev ended: function ended() {5_Ðvxwe ÿÿÿÿoo vO·Ãõdfv return 5_ÐwyxC)ÿÿÿÿoo vO·Ã›‚õBDv, record, [ 'queued', 'reducers', 'ended' ],5_ÐxzyFÿÿÿÿoo vO·Ã õEGv if (queue.queued)5_Ðy{zFÿÿÿÿoo vO·Ã¤õEGv if (ended())5_Ðz|{Fÿÿÿÿoo vO·Ã¥õEGv if (ended(queue))5_Ð{}|F ÿÿÿÿoo vO·Ã©õEGv if (ended(queue)) 5_Ð|~}Fÿÿÿÿoo vO·ÃªõEGv if (!ended(queue)) 5_Ð}~Fÿÿÿÿoo vO·Ã«õEGv if (!ended(queue)) {}5_Ð~€Gÿÿÿÿoo vO·Ã¬õFHv queue.queued.push(item)5_Ð€Hÿÿÿÿoo vO·ÃõGIv react(queue)5_Ð€‚Hÿÿÿÿoo vO·ÃƒõHJw õHJv5_Ðƒ‚6ÿÿÿÿpp vO·Ã¶„õ68xõ68w5_Ð‚„ƒOÿÿÿÿqq vO·ÃÍõOQy õOQx5_Ðƒ…„P ÿÿÿÿrr vO·ÃÐõOQy if ()5_Ð„†…P ÿÿÿÿrr vO·ÃÔõOQy if (ended)5_Ð…‡†Pÿÿÿÿrr vO·ÃÚõOQy if (!ended)5_Ð†ˆ‡Pÿÿÿÿrr vO·ÃÚõOQy if (!ended())5_Ð‡‰ˆPÿÿÿÿrr vO·ÃÝõOQy if (!ended(queue))5_ÐˆŠ‰Pÿÿÿÿrr vO·ÃÞõOQy if (!ended(queue)) {}5_Ð‰‹ŠQÿÿÿÿrr vO·ÃßõPRyF queue.reducers.push({ next: f, state: start, promise: promise })5_ÐŠŒ‹Rÿÿÿÿrr vO·ÃàõQSy react(queue)5_Ð‹ŒRÿÿÿÿrr vO·ÃáõRTz õRTy5_ÐŒŽSÿÿÿÿss vO·ÃäõRUz } else {}5_ÐŽSÿÿÿÿtt vO·ÃåõSU| õSU{5_ÐŽTÿÿÿÿuu vO·ÃêõSU| realize()5_Ð‘Tÿÿÿÿuu vO·ÃîõSU| realize(promise, state)5_Ð’‘nÿÿÿÿuu vO·Ãûõmo| queue.queued.splice(0)5_Ð‘“’nÿÿÿÿuu vO·Äõmo| queue.queued = 05_Ð’”“nÿÿÿÿnnvO·Äõmo| queue.queued = null5_Ð“•”nÿÿÿÿnnvO·Äõmn 5_Ð”–•nÿÿÿÿnnvO·Äõnp| õnp{5_Ð•—–oÿÿÿÿnnvO·Äõnp| queue.queued = null5_Ð–˜—n#ÿÿÿÿnnvO·Ä%õmo|# var reducers = queue.reducers5_Ð—™˜pÿÿÿÿnnvO·Ä0õoq| while (reducers.length) {5_Ð˜š™q&ÿÿÿÿnnvO·Ä;õpr|& var reducer = reducers.shift()5_Ð™›šqÿÿÿÿnnvO·Ä<†õpr| var reducer = reducers[]5_Ðšœ›k ÿÿÿÿnnvO·Åõjl|+ return queue.queued && queue.reducers5_Ð›œkÿÿÿÿnnvO·Å‡õjl|, return !queue.queued && queue.reducers5_ÐœžmÿÿÿÿnnvO·Æwõln| end: function end(queue) {5_ÐŸžj ÿÿÿÿnnvO·Æzõik|" ended: function ended(queue) {5_Ðž ŸjÿÿÿÿnnvO·Æ}õik|# closed: function ended(queue) {5_ÐŸ¡ mÿÿÿÿnnvO·Æ€ˆõln| close: function end(queue) {5_Ð ¢¡PÿÿÿÿnnvO·Æ†‰õOQ| if (!ended(queue)) {5_Ð¡£¢3ÿÿÿÿnnvO·ÆŠõ24| ended: [ protocol ],5_Ð¢¤£4ÿÿÿÿnnvO·ÆŒõ35| end: [ protocol ]5_Ð£¥¤6ÿÿÿÿnnvO·Æõ57|var end = Endable.end5_Ð¤¦¥6 ÿÿÿÿnnvO·Æ’õ57|var colse = Endable.end5_Ð¥§¦6ÿÿÿÿnnvO·Æ•õ57|var close = Endable.end5_Ð¦¨§7 ÿÿÿÿnnvO·Æ™õ68|var ended = Endable.ended5_Ð§©¨7ÿÿÿÿnnvO·Æ›Šõ68|var closed = Endable.ended5_Ð¨ª©8ÿÿÿÿnnvO·ÆŸõ79|exports.end = end5_Ð©«ª8ÿÿÿÿnnvO·Æ¡õ79|exports.close = end5_Ðª¬«2ÿÿÿÿnnvO·Æ¦õ13|var Endable = protocol({5_Ð«¬2ÿÿÿÿnnvO·Æªõ13|var Closabel = protocol({5_Ð¬®6ÿÿÿÿ22vO·Æ¯õ57|var close = Endable.close5_Ð¯®7ÿÿÿÿ22vO·Æ°õ68|var closed = Endable.closed5_Ð®°¯9ÿÿÿÿ22vO·Æ²‹õ8:|exports.Endable = Endable5_Ð¯±°8ÿÿÿÿ22vO·Æµõ79|exports.close = closed5_Ð°²±8ÿÿÿÿ22vO·Æ¶Œõ8:}õ8:|5_Ð±³²Hÿÿÿÿ22vO·ÆÂõGI} if (!ended(queue)) {5_Ð²¶³j ÿÿÿÿ22vO·ÆÊŽõik} Endable, {5_Ð³·´¶+ÿÿÿÿ22vOÃéº‘õEG Enqueueable, {õ/1!exports.Enqueueable = Enqueueableõ-/!var enqueue = Enqueueable.enqueueõ*,var Enqueueable = protocol({5_Ð¶¸·:ÿÿÿÿ7 7vOÃêª“õ9;}exports.Endable = Closable5_Ð·¹¸ÿÿÿÿPFLõ}'/* vim:set ts=2 sw=2 sts=2 expandtab */M/*jshint asi: true undef: true es5: true node: true browser: true devel: true& forin: true latedef: false */1/*global define: true, Cu: true, __URI__: true */2;(function(id, factory) { // Module boilerplate :(3 if (typeof(define) === 'function') { // RequireJS define(factory);: } else if (typeof(require) === 'function') { // CommonJS1 factory.call(this, require, exports, module);= } else if (~String(this).indexOf('BackstagePass')) { // JSM# factory(function require(uri) { var imports = {}; Cu.import(uri, imports); return imports;' }, this, { uri: __URI__, id: id });4 exports.EXPORTED_SYMBOLS = Object.keys(exports); } else { // Browser or alike var globals = this" factory(function require(id) { return globals[id];O }, (globals[id] = {}), { uri: document.location.href + '#' + id, id: id }); }>}).call(this, 'reducers', function(require, exports, module) { 'use strict';0var protocol = require('protocol/core').protocol!var reducers = require('./core'),? Reducible = reducers.Reducible, reduced = reducers.reduced,. is = reducers.is, reduce = reducers.reduce)var eventuals = require('eventual/core'),L defer = eventuals.defer, go = eventuals.go, realize = eventuals.realize, then = eventuals.then$var ego = require('alter-ego/core'),, define = ego.define, record = ego.record=var unbind = Function.call.bind(Function.bind, Function.call)8var slice = Array.slice || unbind(Array.prototype.slice))function identity(value) { return value }var Queueable = protocol({ enqueue: [ protocol, Object ]})var enqueue = Queueable.enqueueexports.enqueue = enqueueexports.Queueable = Queueablevar Closable = protocol({ closed: [ protocol ], close: [ protocol ]})var close = Closable.closevar closed = Closable.closedexports.close = closeexports.closed = closedexports.Closable = Closablevar Reactor = protocol({ react: [ protocol ]})var react = Reactor.reactexports.Reactor = Reactorexports.react = reactvar Queue = define(# record, [ 'queued', 'reducers' ], Queueable, {, enqueue: function enqueue(queue, item) { if (!closed(queue)) { queue.queued.push(item) react(queue) } } }, Reducible, {. reduce: function reduce(f, queue, start) { var promise = defer() if (!closed(queue)) {H queue.reducers.push({ next: f, state: start, promise: promise }) react(queue) } else { realize(promise, start) } return promise } }, Reactor, {" react: function react(queue) { var queued = queue.queued# var reducers = queue.reducers0 while (queued.length && reducers.length) {! var reducer = reducers[0]@ var result = reducer.next(reducer.state, queued.shift())" if (is(result, reduced)) { reducers.shift()0 realize(reducer.promise, result.value) } else { reducer.state = result } } } }, Closable, {$ closed: function closed(queue) {- return !queue.queued && !queue.reducers }," close: function close(queue) {G var reducers = queue.reducers, count = reducers.length, index = 0* queue.queued = queue.reducers = null while (index < count) {' var reducer = reducers[index++]/ realize(reducer.promise, reducer.state) } } })function queue() {( return new Queue(slice(arguments), [])}exports.queue = queue});5_Ð¸º¹+ÿÿÿÿPIõ*,P4 value = is(value, reduced) ? value.value : value5_Ð¹»º+ÿÿÿÿPIõ*,P1 value = value, reduced) ? value.value : value5_Ðº¼»+*ÿÿÿÿPI”õ*,P@ value = value && value.is === reduced) ? value.value : value5_Ð»½¼ ÿÿÿÿPI*õ P%var reduce = require('./core').reduce5_Ð¼¾½ #ÿÿÿÿPI,–õP#var core = require('./core').reduce5_Ð½¿¾%ÿÿÿÿPõ1õ$&Qfunction Queue() {}5_Ð¾À¿%ÿÿÿÿPõ9õ$&Qfunction Queue(channel) {}5_Ð¿ÁÀ%!ÿÿÿÿPõ>õ$'Q"function Queue(channel, queued) {}5_ÐÀÂÁ%ÿÿÿÿPõ?õ%'S õ%'R5_ÐÁÃÂ&ÿÿÿÿPõBõ%'S thi[]5_ÐÂÄÃ&ÿÿÿÿPõCõ%'S this5_ÐÃÅÄ&ÿÿÿÿPõDõ%'S this[]5_ÐÄÆÅ%ÿÿÿÿPõHõ$&S!function Queue(channel, queued) {5_ÐÅÇÆ&ÿÿÿÿPõKõ%'S this[queued]5_ÐÆÈÇ&ÿÿÿÿPõPõ&(T õ&(S5_ÐÇÉÈ'ÿÿÿÿPõRõ&(T this[]5_ÐÈÊÉ'ÿÿÿÿPõTõ&(T this[source]5_ÐÉËÊ#ÿÿÿÿPõcõ#%Uõ#%T5_ÐÊÌË+ÿÿÿÿPõrõ*,U return !queue.result5_ÐËÍÌ+ÿÿÿÿPõyõ*,U return isClosed()5_ÐÌÎÍ+ÿÿÿÿPõ{õ*,U return isClosed(queue[])5_ÐÍÏÎ( ÿÿÿÿPõõ')U this[source] = channel5_ÐÎÐÏ( ÿÿÿÿPõõ')U this[tar] = channel5_ÐÏÑÐ$ ÿÿÿÿ((vPõ†õ#%Uvar source = Name()5_ÐÐÒÑ+ÿÿÿÿ((vPõ‹õ*,U return isClosed(queue[source])5_ÐÑÓÒ)ÿÿÿÿ((vPõ•õ)+Võ)+U5_ÐÒÔÓ*ÿÿÿÿ((vPõ™õ)+Venqueue.define()5_ÐÓÕÔ*ÿÿÿÿ((vPõõ)+V!enqueue.define(Queue, function())5_ÐÔÖÕ*,ÿÿÿÿ((vPõ õ)+V-enqueue.define(Queue, function(queue, value))5_ÐÕ×Ö*.ÿÿÿÿ((vPõ õ),V0enqueue.define(Queue, function(queue, value) {})5_ÐÖØ×*ÿÿÿÿ((vPõ¢õ*,X õ*,W5_Ð×ÙØ+ ÿÿÿÿ((vPõõ*,X isOpen()5_ÐØÚÙ+ÿÿÿÿ((vPõ¯õ*,X isOpen(queue)5_ÐÙÛÚ+ÿÿÿÿ((vPõ³õ*,X isOpen(queue) enqueue()5_ÐÚÜÛ+ÿÿÿÿ((vPõ´õ*,X isOpen(queue) enqueue(queue[])5_ÐÛÝÜ+%ÿÿÿÿ((vPõ¶õ*,X& isOpen(queue) enqueue(queue[target])5_ÐÜÞÝ++ÿÿÿÿ((vPõ¼õ+-X5_ÐÝßÞ+ÿÿÿÿ((vPõ½õ*,Y- isOpen(queue) enqueue(queue[target], value)5_ÐÞàß+ÿÿÿÿ((vPõÁõ*,Y1 if (isOpen(queue) enqueue(queue[target], value)5_Ðßáà+ÿÿÿÿ((vPõÇõ+-Z õ+-Y5_Ðàâá,ÿÿÿÿ((vPõÏõ+-Z else this[]5_Ðáãâ,ÿÿÿÿ((vPõÒõ+-Z else this[queued]5_Ðâäã,ÿÿÿÿ((vPõÕõ+-Z else this[queued].push()5_Ðãåä-ÿÿÿÿ((vPõÙõ,-5_Ðäæå-ÿÿÿÿ((vPõÚõ-/Zõ-/Y5_Ðåçæ.ÿÿÿÿ((vPõàõ-/Zaccumulate.define()5_Ðæèç.#ÿÿÿÿ((vPõäõ-/Z$accumulate.define(Queue, function())5_Ðçéè.%ÿÿÿÿ((vPõäõ-0Z'accumulate.define(Queue, function() {})5_Ðèêé."ÿÿÿÿ((vPõçõ-/[%accumulate.define(Queue, function() {5_Ðéëê.3ÿÿÿÿ((vPõñõ.0\ õ.0[5_Ðêìë,ÿÿÿÿ((vPö õ+-\ else this[queued].push(value)5_Ðëíì, ÿÿÿÿ((vPö õ+-\! else queued[queued].push(value)5_Ðìîí/ÿÿÿÿ((vPö"õ.0\ 5_Ðíïî/ÿÿÿÿ((vPö&õ.0\ enqueue()5_Ðîðï/ ÿÿÿÿ((vPö)õ.0\ accumulate()5_Ðïñð/ÿÿÿÿ((vPö*õ.0\ accumulate(queue[])5_Ððòñ/ÿÿÿÿ((vPö,õ.0\ accumulate(queue[target])5_Ðñóò/'ÿÿÿÿ((vPö/õ.0\( accumulate(queue[target], next, state)5_Ðòôó/&ÿÿÿÿ((vPö1õ.0\' accumulate(queue[target], next, stat)5_Ðóõô.4ÿÿÿÿ/(/"v"Pö5—õ-/\7accumulate.define(Queue, function(queue, next, start) {5_ÐôöõÿÿÿÿvPöD˜õRõ\var Name = require('name')var Method = require('method')var core = require('./core'),0 reduce = core.reduce, reduced = core.reduced-var eventuals = require('eventual/eventual'),8 defer = eventuals.defer, deliver = eventuals.deliver=var unbind = Function.call.bind(Function.bind, Function.call)8var slice = Array.slice || unbind(Array.prototype.slice)5_Ðõ÷öÿÿÿÿvPöGõ// Method to enqueue values.5_Ðöø÷ÿÿÿÿvPöHõvar enqueue = Method()5_Ð÷ùøÿÿÿÿvPöHõexports.enqueue = enqueue5_ÐøúùÿÿÿÿvPöHõ5_ÐùûúÿÿÿÿvPöHõ// Method to close a queue.5_ÐúüûÿÿÿÿvPöHõvar close = Method()5_ÐûýüÿÿÿÿvPöHõexports.close = close5_ÐüþýÿÿÿÿvPöIõ5_ÐýÿþÿÿÿÿvPöIõvar isClosed = Method()5_ÐþÿÿÿÿÿvPöIõexports.isClosed = isClosed5_ÐÿÿÿÿÿvPöIõ5_ÐÿÿÿÿvPöIõvar react = Method()5_ÐÿÿÿÿvPöIõexports.react = react5_ÐÿÿÿÿvPöJõ5_ÐÿÿÿÿvPöJõvar state = Name()5_ÐÿÿÿÿvPöJõvar result = Name()5_ÐÿÿÿÿvPöL™õvar next = Name()5_ÐÿÿÿÿvPöhšõAõNvar core = require('../core'),> into = core.into, flatten = core.flatten, take = core.take-var accumulators = require('../accumulator'), reduce = accumulators.reduce%var channels = require('../channel'),; channel = channels.channel, enqueue = channels.enqueue,9 close = channels.close, isClosed = channels.isClosed, isOpen = channels.isOpen,% sequential = channels.sequential, parallel = channels.parallelvar hubs = require('../hub'), hub = hubs.hub5_Ð "ÿÿÿÿvPörõ!"%close.define(Queue, function(queue) {5_Ð "ÿÿÿÿvPörõ!" if (!isClosed(queue)) {5_Ð "ÿÿÿÿvPörõ!" var value = queue[state]5_Ð "ÿÿÿÿvPösõ!"? value = value && value.is === reduced ? value.value : value5_Ð "ÿÿÿÿvPösõ!"! deliver(queue[result], value)5_Ð "ÿÿÿÿvPösõ!"E queue[next] = queue[state] = queue[result] = queue[queued] = null5_Ð "ÿÿÿÿvPösõ!" }5_Ð"ÿÿÿÿvPösõ!" return queue5_Ð"ÿÿÿÿvPösõ!"})5_Ð"ÿÿÿÿvPötõ!"%react.define(Queue, function(queue) {5_Ð"ÿÿÿÿvPötõ!"- var values = queue[queued], f = queue[next]5_Ð"ÿÿÿÿvPötõ!" while (values.length && f) {5_Ð"ÿÿÿÿvPötõ!"2 queue[state] = f(queue[state], values.shift())5_Ð"ÿÿÿÿvPötõ!"# if (is(queued[state], reduced))5_Ð"ÿÿÿÿvPötõ!" return close(queue)5_Ð"ÿÿÿÿvPöuõ!" }5_Ð"ÿÿÿÿvPöuõ!"})5_Ð"ÿÿÿÿvPöuõ!"-enqueue.define(Queue, function(queue, item) {5_Ð"ÿÿÿÿvPöuõ!" if (!isClosed(queue)) {5_Ð"ÿÿÿÿvPöuõ!" queue[queued].push(item)5_Ð"ÿÿÿÿvPöuõ!" react(queue)5_Ð"ÿÿÿÿvPövõ!" }5_Ð"ÿÿÿÿvPövõ!" return queue5_Ð "ÿÿÿÿvPövõ!"})5_Ð! "ÿÿÿÿvPövõ!"0reduce.define(Queue, function(queue, f, start) {5_Ð "!"ÿÿÿÿvPövõ!"# if (isClosed(queue)) return start5_Ð!#""ÿÿÿÿvPövõ!" queue[state] = start5_Ð"$#"ÿÿÿÿvPöwõ!" queue[next] = f5_Ð#%$"ÿÿÿÿvPöwõ!" react(queue)5_Ð$&%"ÿÿÿÿvPöwõ!" return queue[result]5_Ð%'&"ÿÿÿÿvPöwõ!"})5_Ð&('"ÿÿÿÿvPöwõ!"5_Ð')("ÿÿÿÿvPöwõ!"function queue() {5_Ð(*)"ÿÿÿÿvPöxõ!" var result = new Queue()5_Ð)+*"ÿÿÿÿvPöxõ!"# result[queued] = slice(arguments)5_Ð*,+"ÿÿÿÿvPöxõ!" result[result] = defer()5_Ð+-,"ÿÿÿÿvPöxõ!" result[state] = null5_Ð,.-"ÿÿÿÿvPöxõ!" result[next] = null5_Ð-/."ÿÿÿÿvPöxõ!" return result5_Ð.0/"ÿÿÿÿvPöyõ!"}5_Ð/10"ÿÿÿÿvPöyõ!"exports.queue = queue5_Ð021ÿÿÿÿvPö„›õ"õ!5_Ð132%ÿÿÿÿvPö·õ%'õ%5_Ð243&ÿÿÿÿvPö¿õ%'isOpen.define()5_Ð354&ÿÿÿÿvPöÂõ% isOpen.define(Queue, function())5_Ð465&$ÿÿÿÿvPöÄõ%'%isOpen.define(Queue, function(queue))5_Ð576&&ÿÿÿÿvPöÅõ%(isOpen.define(Queue, function(queue) {})5_Ð687&ÿÿÿÿvPöÆõ&(( õ&('5_Ð798'ÿÿÿÿvPöÉõ&(( return isOpen()5_Ð8:9'ÿÿÿÿvPöËœõ&(( return isOpen(queued)5_Ð9;:ÿÿÿÿvPööõ )õ(5_Ð:<; ÿÿÿÿvPöûõ,#dispose.define(Hub, function(hub) {5_Ð;=<ÿÿÿÿvPöþõ,%dispose.define(Hub, function(queue) {5_Ð<>=ÿÿÿÿvP÷õ, hub[source] = null5_Ð=?>ÿÿÿÿvP÷õ, queue[source] = null5_Ð>@?ÿÿÿÿvP÷õ, hub[accumulators] = null5_Ð?A@ÿÿÿÿvP÷ õ, queue[accumulators] = null5_Ð@BA$ÿÿÿÿvP÷9õ$&- õ$&,5_ÐACB%ÿÿÿÿvP÷;õ$&- if ()5_ÐBDC% ÿÿÿÿvP÷=õ$&- if (isOpen())5_ÐCED&ÿÿÿÿvP÷@õ$&- if (isOpen(queue))(accumulate(queue[target], next, initial)õ%'-* accumulate(queue[target], next, initial)5_ÐDFE%ÿÿÿÿvP÷Eõ$&,= if (isOpen(queue)) accumulate(queue[target], next, initial)5_ÐEGF%ÿÿÿÿvP÷Gõ$',> if (!isOpen(queue)) accumulate(queue[target], next, initial)5_ÐFHG&ÿÿÿÿvP÷Iõ%'-* accumulate(queue[target], next, initial)5_ÐGIH&ÿÿÿÿvP÷Ižõ&(. õ&(-5_ÐHJI$ÿÿÿÿvP÷]õ$)/ õ$&.5_ÐIKJ%ÿÿÿÿvP÷`õ$&21 if (isClosed(hub)) return next(end(), initial)5_ÐJLK%ÿÿÿÿvP÷gõ$&20 if (isClosed(hub)) return next(end(), initial)5_ÐKML*ÿÿÿÿ**+v+P÷sõ)+2, accumulate(queue[target], next, initial)5_ÐLNM%ÿÿÿÿ**+v+P÷tõ%'3 õ%'25_ÐMON&ÿÿÿÿ+++v+P÷uõ%'3, accumulate(queue[target], next, initial)5_ÐNPO'ÿÿÿÿ+++v+P÷wõ&'8 hub[accumulators].push({ next: next, state: initial })5_ÐOQP(ÿÿÿÿ**+v+P÷zõ'(5_ÐPRQ(ÿÿÿÿ))+v+P÷{õ'( if (!isOpen(queue)) {5_ÐQSR(ÿÿÿÿ((+v+P÷{õ'( 5_ÐRTS(ÿÿÿÿ((+v+P÷|õ'( }5_ÐSUT'ÿÿÿÿ((+v+P÷Ÿõ&(. if (!isOpen(hub)) open(hub)5_ÐT_U'ÿÿÿÿ((+v+P÷„¡õ&(. if (!isOpen(queue)) open(hub)5_ÐU`V_(ÿÿÿÿ((+v+P÷·õ(*/õ(*.5_Ð_a`)ÿÿÿÿ((+v+P÷¼õ(*/ open.define()5_Ð`ba)ÿÿÿÿ((+v+P÷Àõ(*/open.define(Queue, function())5_Ðacb)"ÿÿÿÿ((+v+P÷Áõ(*/#open.define(Queue, function(queue))5_Ðbdc)$ÿÿÿÿ((+v+P÷Â¢õ(+/&open.define(Queue, function(queue) {})5_Ðced)ÿÿÿÿ((+v+P÷úõ()$open.define(Queue, function(queue) {5_Ðdfe)ÿÿÿÿ((+v+P÷ûõ()})5_Ðegf%ÿÿÿÿ((+v+P÷ýõ%'/ õ%'.5_Ðfhg(ÿÿÿÿ((vPøõ')/! if (!isOpen(queue)) open(queue)5_Ðgih&ÿÿÿÿ((vPøõ%'/ var opened = 5_Ðhji( ÿÿÿÿ((vPø £õ')/ if (!) open(queue)5_Ðikjÿÿÿÿ((vPøõ0õ/5_Ðjlkÿÿÿÿ))vPøõ0function open()5_Ðkmlÿÿÿÿ))vPøõ0function open() {}5_Ðlnmÿÿÿÿ**vPø¤õ15_Ðmonÿÿÿÿ++vPøõ2function open() {5_Ðnpoÿÿÿÿ++vPø¥õ2function open(queued) {5_Ðoqpÿÿÿÿ++vPøõ3 õ25_Ðprqÿÿÿÿ,,vPøtõ4õ35_Ðqsrÿÿÿÿ--vPø|õvar 5_Ðrts%ÿÿÿÿ,,vPø†õ$&32 if (isOpen(queue)) enqueue(queue[target], value)5_Ðsut%ÿÿÿÿ,,vPøŠ¦õ$&32 if (isOpen(queue)) enqueue(queue[target], value)5_Ðtvuÿÿÿÿ,,vPø¤õfunction isReadyõ4õ35_Ðuwvÿÿÿÿ..vPø®õ5function isReady()5_Ðvxwÿÿÿÿ..vPø°õ5function isReady(queued)5_Ðwyxÿÿÿÿ..vPø±õ5function isReady(queue)5_Ðxzyÿÿÿÿ..vPø±õ5function isReady(queue) {}5_Ðy{zÿÿÿÿ//vPø²õ7 õ65_Ðz|{ÿÿÿÿ00vPøºõ7 return isOpen()5_Ð{}|ÿÿÿÿ00vPø¼õ7 return isOpen(queued)5_Ð|~}ÿÿÿÿ00vPø¿õ7function isReady(queue) {5_Ð}~ÿÿÿÿ00vPøÅõ7 return isOpen(queue)5_Ð~€ ÿÿÿÿ00vPøÎõ7! return isOpen(queue) && queue[]5_Ð€ÿÿÿÿ00vPøÐ§õ7' return isOpen(queue) && queue[queued]5_Ð€‚)ÿÿÿÿ00vPøØõ(*72 if (isOpen(queue)) enqueue(queue[target], value)5_Ðƒ‚0ÿÿÿÿ00vPù õ/17 if (!opened) open(queue)5_Ð‚„ƒ ÿÿÿÿ00vPùõ7function open(queue) {5_Ðƒ…„ÿÿÿÿ00vPùõ7 var 5_Ð„†…ÿÿÿÿ00vPù(õ7 var values = queue5_Ð…‡†ÿÿÿÿ00vPù(õ7 var values = queue[]5_Ð†ˆ‡ÿÿÿÿ00vPù+õ8 õ75_Ð‡‰ˆ ÿÿÿÿ11vPù.õ8 while ()5_ÐˆŠ‰ÿÿÿÿ11vPù3õ9 õ85_Ð‰‹Šÿÿÿÿ22vPù?õ9 enqueue()5_ÐŠŒ‹ÿÿÿÿ22vPùAõ9 enqueue(queue[])5_Ð‹Œÿÿÿÿ22vPùBõ9 enqueue(queue[target])5_ÐŒŽÿÿÿÿ22vPùRõ9 while (values.length)&enqueue(queue[target], values.shift())õ9* enqueue(queue[target], values.shift())5_ÐŽÿÿÿÿ11vPùUõ9 õ85_ÐŽ ÿÿÿÿ22vPù^¨õ9 dispose()5_Ð‘ÿÿÿÿ22vPùd©õ: õ95_Ð’‘3ÿÿÿÿ33vPùjªõ35; õ35:5_Ð‘“’- ÿÿÿÿ33vPùq«õ-/< õ-/;5_Ð’”“7ÿÿÿÿ44vPùõ<7 channel = channels.channel, close = channels.close,5_Ð“•”ÿÿÿÿ44vPù•¬õ channel = channels.channel, 5_Ð”–•Aÿÿÿÿ33vPù¤õ ;A accumulate = core.accumulate, accumulated = core.accumulated,5_Ð•—– ÿÿÿÿ33vPù¬õ ;" accumulate = core.accumulate, accumulator = core.accumulatorõ;2 end = core.end, accumulator = core.accumulator5_Ð–˜—/ÿÿÿÿ22vPùÁ¯õ./2 if (isClosed(queue)) return next(end(), initial)5_Ð—™˜ÿÿÿÿ11vPùÖ±õ5_Ð˜š™8ÿÿÿÿ00vPûðõ9;function queuedõ8õ85_Ð™›š:ÿÿÿÿ00vPûóõ9;function queued()5_Ðšœ›:ÿÿÿÿ00vPûõõ9function queue()5_Ð›œ:ÿÿÿÿ00vPüõ9;function queue(target)5_Ðœž:ÿÿÿÿ00vPü²õ9function queue(target) {}5_ÐŸž"ÿÿÿÿ00vPüõ<õ;5_Ðž Ÿÿÿÿÿ11vPü³õ channel = channels5_ÐŸ¡ :ÿÿÿÿ00vPü/õ:<< õ:<;5_Ð ¢¡;ÿÿÿÿ00vPü6¶õ:<< return new Queue()5_Ð¡£¢<ÿÿÿÿ00vPÿUõ<õ<5_Ð¢¤£=ÿÿÿÿ00vPÿb·õ<exports.queues = queues5_Ð£¥¤=ÿÿÿÿ00vPÿi¹õ<exports.queue = queued5_Ð¤¦¥(ÿÿÿÿ00vPÿàõ(*> õ(*=5_Ð¥§¦)ÿÿÿÿ11vPÿäõ(*> console.log()5_Ð¦¨§)ÿÿÿÿ11vPÿæºõ(*> console.log(isDrained())5_Ð§©¨)ÿÿÿÿ11vPÿíõ(*> console.log(isDrained(queue))5_Ð¨ª©)ÿÿÿÿ11vPÿî»õ(*> console.log('')5_Ð©«ª)ÿÿÿÿ11vPÿô¼õ(*> console.log('>>>>>>')5_Ðª¬«)ÿÿÿÿ11vPÿùõ(*> console.log('>>>>>>', queue)5_Ð«¬))ÿÿÿÿ11vPÿû½õ(*>+ console.log('>>>>>>', queue, isDrained())5_Ð¬®)(ÿÿÿÿ11vP ¾õ(*>0 console.log('>>>>>>', queue, isDrained(queue))5_Ð¯®8ÿÿÿÿ11vPõ79> return isOpen(queue)5_Ð®°¯8ÿÿÿÿ11vP¿õ79> return isOpen(queue[])5_Ð¯±°)ÿÿÿÿ11vP!Àõ()- console.log('>>>>>>', queue, isOpen(queue))5_Ð°²±(ÿÿÿÿ00vPƒõ(*=5_Ð±³²)ÿÿÿÿ11vP‹õ(*>5_Ð²´³)ÿÿÿÿ11vPŽÁõ(*> console.log()5_Ð³µ´)ÿÿÿÿ11vP—õ(*> console.log(queue)5_Ð´¶µ)ÿÿÿÿ11vP—Âõ(*> console.log(queue[])5_Ðµ·¶)ÿÿÿÿ11vP Ãõ(*> console.log(queue[source])5_Ð¶¸·)ÿÿÿÿ11vP¨õ(*> console.log(queue[target])5_Ð·¹¸)#ÿÿÿÿ11vPªÄõ(*># console.log(isOpen(queue[target])5_Ð¸º¹)ÿÿÿÿ11vP»Åõ(*>$ console.log(isOpen(queue[target]))5_Ð¹»º)ÿÿÿÿ11vPÄÆõ()' console.log(isDrained(queue[target]))5_Ðº¼»)ÿÿÿÿ00vPÊÇõ(+=5 if (isDrained(queue)) enqueue(queue[target], value)5_Ð»½¼(ÿÿÿÿ11vPúõ(*? õ(*>5_Ð¼¾½)ÿÿÿÿ22vPÿÈõ(*? console.log()5_Ð½¿¾)ÿÿÿÿ22vPÉõ(*? console.log(queue)5_Ð¾À¿)ÿÿÿÿ22vPõ)+@ õ)+?5_Ð¿ÁÀ*ÿÿÿÿ33vPõ)+@ console.log()5_ÐÀÂÁ*ÿÿÿÿ33vP õ)+@ console.log('')5_ÐÁÃÂ*ÿÿÿÿ33vP õ)+@ console.log('<<')5_ÐÂÄÃ*ÿÿÿÿ33vPÊõ)+@ console.log('<<', isDrained())5_ÐÃÅÄ*$ÿÿÿÿ33vP#Ëõ)+@% console.log('<<', isDrained(queue))5_ÐÄÆÅ)ÿÿÿÿ33vP&Ìõ(*@ console.log('>>>', queue)5_ÐÅÇÆ*+ÿÿÿÿ33vP)Íõ)+@, console.log('<<', isDrained(queue), value)5_ÐÆÈÇ:ÿÿÿÿ33vP[õ@: enqueue = channels.enqueue, dispose = channels.dispose5_ÐÇáÈÿÿÿÿ44vPfÔõA close = queue.close5_ÐÈâÉá(ÿÿÿÿ44vP3õ(*Bõ(*A5_Ðáãâ) ÿÿÿÿ55vP8õ(*Bclose.define()5_Ðâäã)ÿÿÿÿ55vP;õ(*Bclose.define(Queue, function())5_Ðãåä) ÿÿÿÿ55vP;õ(+B"close.define(Queue, function() {})5_Ðäæå)ÿÿÿÿ66vP<õ)+D õ)+C5_Ðåçæ*ÿÿÿÿ77vPBõ)+D return close()5_Ðæèç)ÿÿÿÿ77vPEõ(*D close.define(Queue, function() {5_Ðçéè*ÿÿÿÿ77vPFõ)+D return close()5_Ðèêé*ÿÿÿÿ77vPHõ)+D return close(queue[])5_Ðéëê)"ÿÿÿÿ77vPJõ(*D%close.define(Queue, function(queue) {5_Ðêìë*ÿÿÿÿ77vPMÕõ)+D return close(queue[target])5_Ðëíì)ÿÿÿÿ)+vPeõ(*D,close.define(Queue, function(queue, value) {$ return close(queue[target], value)})5_Ðìîí)ÿÿÿÿ))vPeÖõ()5_Ðíïî<ÿÿÿÿ))vPh×õ<@Bõ<>A5_Ðîðï=ÿÿÿÿ))vP‰õ=?E õ=?D5_Ðïñð>ÿÿÿÿ))vP‹õ=?E if ()5_Ððòñ>ÿÿÿÿ))vPõ=?E if (value !== undefined)5_Ðñóò>#ÿÿÿÿ))vP’õ=?E$ if (value !== undefined) enqueue()5_Ðòøó?#ÿÿÿÿ))vP–Ýõ>@E$ return close(queue[target], value)5_Ðóùöø:ÿÿÿÿ))vPãõ:<F õ:<E5_Ðøúù;ÿÿÿÿ))vPæõ:<F console.log()5_Ðùûú;ÿÿÿÿ))vPéõ:<F console.log(queue,)5_Ðúüû;ÿÿÿÿ))vPïÞõ:<F console.log('open?', queue,)5_Ðûýü;ÿÿÿÿ))vPòõ:<F console.log('open?', queue)5_Ðüý;ÿÿÿÿ))vPóáõ:<F console.log('open?', queue[])5_Ðýþÿÿÿÿ'v'Púâõ dispose(queue)5_Ð$ÿÿÿÿ'v'Pýõ#$'dispose.define(Queue, function(queue) {5_Ð$ÿÿÿÿ'v'Pþõ#$ queue[target] = null5_Ð$ÿÿÿÿ'v'Pþõ#$ queue[target] = null5_Ð$ÿÿÿÿ'v'Pÿãõ#$})5_Ðÿÿÿÿ'v'PõB õA5_Ðÿÿÿÿ'v'PõB queue[]5_Ð ÿÿÿÿ'v'P äõB queue[queued]5_Ð 7ÿÿÿÿ'v'Påõ67% console.log('open?', queue[target])5_Ð &ÿÿÿÿ'v'Põ%&" console.log('>>>', queue, value)5_Ð &ÿÿÿÿ'v'Pæõ%&% console.log('<<', isDrained(queue))5_Ð <ÿÿÿÿ'v'PŒõ<>@ õ<>?5_Ð =ÿÿÿÿ'v'P•õ<>@ var value = Object.create()5_Ð =!ÿÿÿÿ'v'P–õ=?A õ=?@5_Ð<ÿÿÿÿ'v'Pšõ;=Afunction queue(target) {5_Ð<ÿÿÿÿ'v'Põ;=Afunction queue(input) {5_Ð="ÿÿÿÿ<<vP¡õ<>A# var value = Object.create(target)5_Ð> ÿÿÿÿ<<vP£õ=?A values[]5_Ð>ÿÿÿÿ<<vP¥õ=?A values[target]5_Ð>ÿÿÿÿ<<vP¨õ>@A5_Ð>ÿÿÿÿ<<vPõ=?B values[target] = output5_Ð>ÿÿÿÿ<<vP®õ>@C õ>@B5_Ð? ÿÿÿÿ<<vP°õ>@C values[]5_Ð?ÿÿÿÿ<<vP±õ>@C value[]5_Ð?ÿÿÿÿ<<vP³õ>@C value[queued]5_Ð?ÿÿÿÿ<<vP¶õ?AD õ?AC5_Ð@ÿÿÿÿ<<vP¸õ?AD return values5_ÐAÿÿÿÿ<<vP¹õ@A5_ÐAÿÿÿÿ<<vP¹çõ@A return new Queue(target, [])5_Ð%ÿÿÿÿ%0vPæõ$&B .enqueue.define(Queue, function(queue, value) { if (isDrained(queue))! enqueue(queue[target], value) else queue[queued].push(value) return queue})9accumulate.define(Queue, function(queue, next, initial) { var opened = isOpen(queue)* accumulate(queue[target], next, initial) if (!opened) drain(queue) return queue})(isClosed.define(Queue, function(queue) {5_Ð 5ÿÿÿÿ%%vPçõ5C7õ5765_Ð! 5ÿÿÿÿ%%vPêõ57Dõ57C5_Ð #!7ÿÿÿÿ%%vPòéõ57Dqueue.enqueue = function(queue, value) {õ68D.enqueue.define(Queue, function(queue, value) {5_Ð!$"#;ÿÿÿÿ%%vPõ:<C})5_Ð#%$<ÿÿÿÿ%%vP õ;=C9accumulate.define(Queue, function(queue, next, initial) {5_Ð$&%<,ÿÿÿÿ%%vPõ;=CLqueue.accumulate = accumulate.define(Queue, function(queue, next, initial) {5_Ð%'&Aÿÿÿÿ%%vPêõ@BC})5_Ð&('3ÿÿÿÿ%%vPõ35D õ35C5_Ð')(4ÿÿÿÿ%%vP&õ35D enqueue.implement()5_Ð(*)4'ÿÿÿÿ%%vP*õ46E õ46D5_Ð)+*5ÿÿÿÿ%%vP/ëõ46E accumulate.implement()5_Ð*,+Cÿÿÿÿ%%vPAõCEFõCEE5_Ð+-,Dÿÿÿÿ%%vPIõCEFqueue.close = function()5_Ð,.-D%ÿÿÿÿ%%vPLõCEF%queue.close = function(queue, values)5_Ð-/.D'ÿÿÿÿ%%vPMõCFF(queue.close = function(queue, values) {}5_Ð.0/Dÿÿÿÿ%%vPNõDFH õDFG5_Ð/10Eÿÿÿÿ%%vPOõDFH if ()5_Ð021Eÿÿÿÿ%%vPQõDFH if (values)5_Ð132Eÿÿÿÿ%%vPRõDFH if (value)5_Ð243Eÿÿÿÿ%%vPUõDFH if (value) 5_Ð354Eÿÿÿÿ%%vP\õDFH if (value !== undefined) 5_Ð465E#ÿÿÿÿ%%vP]õDFH$ if (value !== undefined) enqueue()5_Ð576E0ÿÿÿÿ%%vPeõDFH1 if (value !== undefined) enqueue(queue, values)5_Ð687E.ÿÿÿÿ%%vPfõEGI õEGH5_Ð798Fÿÿÿÿ%%vPmõEGI return close()5_Ð8:9Fÿÿÿÿ%%vPnõEGI return close(queue[])5_Ð9;:D$ÿÿÿÿ%%vPwìõCEI'queue.close = function(queue, values) {5_Ð:<; ÿÿÿÿ .vP„îõ!:õ!I function Queue(channel, items) { this[queued] = items this[target] = channel}(isClosed.define(Queue, function(queue) { return isClosed(queue[target])})&isOpen.define(Queue, function(queue) { return isOpen(queue[target])}),close.define(Queue, function(queue, value) {0 if (value !== undefined) enqueue(queue, value) return close(queue[target])})5_Ð;=<: ÿÿÿÿ vPÆïõ9exports.queue = queue5_Ð<>= ÿÿÿÿ vP õ :@ accumulate = core.accumulate, accumulator = core.accumulator5_Ð=?>ÿÿÿÿ vPõ :: convert = core.convert, accumulator = core.accumulator5_Ð>@?9ÿÿÿÿ vPõ:W convert = core.convert, accumulate = core.accumulatoraccumulator = core.accumulator5_Ð?A@9ÿÿÿÿ!!vPõ ;9 convert = core.convert, accumulate = core.accumulator5_Ð@BA ÿÿÿÿ!!vP"ðõ " accumulator = core.accumulator5_ÐACB"#ÿÿÿÿ vP5õ!#:# var value = Object.create(output)5_ÐBDC"ÿÿÿÿ vP8õ!#: var value = convert()5_ÐCED%ÿÿÿÿ%(%vPHõ$&:) enqueue.implement(value, queue.enqueue)5_ÐDFE"ÿÿÿÿ%(%vPIõ"$; õ"$:5_ÐEGF&ÿÿÿÿ&(&vPJõ%& 5_ÐFHG&ÿÿÿÿ&(&vPKòõ%&/ accumulate.implement(value, queue.accumulate)5_ÐGIH ÿÿÿÿ&(&vP õ9var target = Name()5_ÐHJI,ÿÿÿÿ&(&vP%óõ9> while (values.length) enqueue(queue[target], values.shift())5_ÐIKJ$ÿÿÿÿ&(&vP,õ#%9 value[target] = output5_ÐJLK!ÿÿÿÿ&(&vP.õ "9function queue(output) {5_ÐKML$ÿÿÿÿ&(&vP1ôõ#%9 value[output] = output5_ÐLNM*ÿÿÿÿ&(&vP4õ)+9! enqueue(queue[target], value)5_ÐMON0ÿÿÿÿ&(&vP7õõ/19* accumulate(queue[target], next, initial)5_ÐNPO6ÿÿÿÿ&(&vP9öõ579 return close(queue[target])5_ÐOQP"ÿÿÿÿ&(&vPI÷õ!#9/ var value = convert(output, queue.accumulate)5_ÐPRQ4ÿÿÿÿ&(&vP bõ34&queue.close = function(queue, value) {5_ÐQSR4ÿÿÿÿ&(&vP bõ340 if (value !== undefined) enqueue(queue, value)5_ÐRTS4ÿÿÿÿ&(&vP cõ34 return close(queue[output])5_ÐSYT4ÿÿÿÿP cùõ34}5_ÐTZXY;ÿÿÿÿ&(&vP õ5; isClosed = channels.isClosed, isOpen = channels.isOpen,5_ÐY[Zÿÿÿÿ&(&vP õ5" isClosed = channels.isClosed, 7enqueue = channels.enqueue, dispose = channels.dispose,õ5; enqueue = channels.enqueue, dispose = channels.dispose,5_ÐZ\[Yÿÿÿÿ%(%vP “õ4Y isClosed = channels.isClosed, enqueue = channels.enqueue, dispose = channels.dispose,5_Ð[]\"ÿÿÿÿ%(%vP šõ4= isClosed = channels.isClosed, enqueue = channels.enqueue,5_Ð\^]ÿÿÿÿ%(%vP œúõ4 enqueue = channels.enqueue,close = channels.closeõ4 close = channels.close5_Ð]_^ÿÿÿÿ$($vP ¢ûõ3( return isOpen(queue) && !queue[queued]5_Ð^‚_-ÿÿÿÿ$($vP ©õ,- var opened = isOpen(queue)5_Ð_ƒ`‚. ÿÿÿÿ$($vP Jõ-/2 if (!opened) drain(queue)5_Ð‚„ƒ.ÿÿÿÿ$($vP Oõ-/2 if (!isDrained()) drain(queue)5_Ðƒ…„.ÿÿÿÿ..$v$P |õ-/2% if (!isDrained(queue)) drain(queue)5_Ð„†…,ÿÿÿÿ..$v$P |õ,.3 õ,.25_Ð…Œ†/ÿÿÿÿ//$v$P ~ õ./ 5_Ð†‡Œ,ÿÿÿÿ//$v$P ƒõ,.3 õ,.25_ÐŒŽ- ÿÿÿÿ00$v$P ‰õ,.3 accumulate()5_ÐŽ-ÿÿÿÿ00$v$P ‹õ,.3 accumulate(append())5_ÐŽ-ÿÿÿÿ00$v$P Žõ,.3 accumulate(append(queue[]))5_Ð‘- ÿÿÿÿ00$v$P õ,.3" accumulate(append(queue[queue]))5_Ð’‘-(ÿÿÿÿ00$v$P “õ,.3+ accumulate(append(queue[queue], queue[]))5_Ð‘“’-0ÿÿÿÿ00$v$P •õ,.31 accumulate(append(queue[queue], queue[output]))5_Ð’”“8ÿÿÿÿ00$v$P £ õ 38 convert = core.convert, accumulate = core.accumulate5_Ð“•”-ÿÿÿÿ00$v$P «õ-/4 õ-/35_Ð”–•.ÿÿÿÿ11$v$P ´õ.045_Ð•—–/ÿÿÿÿ22$v$P ·õ.055_Ð–˜—, ÿÿÿÿ22$v$P Ãõ,.6 õ,.55_Ð—™˜-ÿÿÿÿ33$v$P Éõ,.6 console.log()5_Ð˜š™-ÿÿÿÿ33$v$P Ëõ,.6 console.log(queue[])5_Ð™›š-ÿÿÿÿ33$v$P Ìõ,.6 console.log(queue[queue])5_Ðšœ›.ÿÿÿÿ33$v$P Îõ-/6@ accumulate(append(queue[queue], queue[output]), next, initial)5_Ð›œ-ÿÿÿÿ33$v$P Õõ,- console.log(queue[queued])5_Ðœž0ÿÿÿÿ22$v$P Üõ/0% if (!isDrained(queue)) drain(queue)5_ÐŸž0ÿÿÿÿ11$v$P Ýõ/0* accumulate(queue[output], next, initial)5_Ðž Ÿ0ÿÿÿÿ00$v$P Ý õ/0 return queue5_ÐŸ¡ /ÿÿÿÿ00$v$P çõ./ return queue5_Ð ¢¡ÿÿÿÿ//$v$P þõfunction drain(queue) {5_Ð¡£¢ÿÿÿÿ..$v$P ÿõ var values = queue[queued]5_Ð¢¤£ÿÿÿÿ--$v$P ÿõ> while (values.length) enqueue(queue[output], values.shift())5_Ð£¥¤ÿÿÿÿ,,$v$P ÿõ queue[queued] = null5_Ð¤¦¥ÿÿÿÿ++$v$P õ return queue5_Ð¥§¦ÿÿÿÿ**$v$P õ}5_Ð¦ª§ÿÿÿÿ))$v$P õ5_Ð§«©ª6ÿÿÿÿ(($v$P uõ*6 enqueue = channels.enqueue, close = channels.close5_Ðª¬«ÿÿÿÿ(($v$P wõ* enqueue = channels.enqueue,5_Ð«¬ÿÿÿÿP °îõ *$var channels = require('./channel'),5_Ð¬®ÿÿÿÿP °ðõ * var emit = require('./channel'),5_Ð¯®ÿÿÿÿP °òõ *var emit = require('./signal'),5_Ð®°¯ÿÿÿÿP °õõ enqueue = channels.enqueue5_Ð¯±°ÿÿÿÿP °øõ!! enqueue(queue[output], value)õ(queue.enqueue = function(queue, value) {õ) enqueue.implement(value, queue.enqueue)5_Ð°²±ÿÿÿÿP|ÅÖõvar Method = require('method')5_Ð±³²ÿÿÿÿP|Å×õ5_Ð²´³ÿÿÿÿP|Å×õ5_Ð³µ´ÿÿÿÿPƒœªõvar Name = require('name')5_Ð´¶µÿÿÿÿPƒœõ %N convert = core.convert, accumulate = core.accumulate, append = core.append5_Ðµ·¶ÿÿÿÿPƒœ±õ %Nvar convert = core.convert, accumulate = core.accumulate, append = core.append5_Ð¶¸·ÿÿÿÿPƒœ³õ %Kvar convert = require(), accumulate = core.accumulate, append = core.append5_Ð·¹¸ÿÿÿÿPƒœ´õ %Mvar convert = require(""), accumulate = core.accumulate, append = core.append5_Ð¸º¹ÿÿÿÿPƒœ·õvar core = require('./core'),5_Ð¹»º$ÿÿÿÿPƒœ¹õ $Vvar convert = require("./convert"), accumulate = core.accumulate, append = core.append5_Ðº¼»ÿÿÿÿPƒœ¼õ %6var accumulate = core.accumulate, append = core.append5_Ð»½¼ÿÿÿÿPƒœ¾õ %;var accumulate = require().accumulate, append = core.append5_Ð¼¾½ÿÿÿÿPƒœ¾õ %=var accumulate = require("").accumulate, append = core.append5_Ð½¿¾4ÿÿÿÿPƒœÁõ %Ivar accumulate = require("./accumulate").accumulate, append = core.append5_Ð¾À¿'ÿÿÿÿPƒœÃõ &õ %5_Ð¿ÁÀ ÿÿÿÿPƒœÈõ &var concat = require()5_ÐÀÃÁ ÿÿÿÿPƒœÈõ &var concat = require("")5_ÐÁÄÂÃ=ÿÿÿÿPƒœÔõ &=var accumulate = require("./accumulate") append = core.append5_ÐÃÅÄ ÿÿÿÿPƒœØõ 5_ÐÄÆÅÿÿÿÿPƒœÝõ %var queued = Name()5_ÐÅÇÆÿÿÿÿPƒœßõ %var queued = ""5_ÐÆÈÇÿÿÿÿPƒœãõ %var queued = "queued@"5_ÐÇÉÈÿÿÿÿPƒœëõ% 'use strict';5_ÐÈÊÉÿÿÿÿPƒœíõ% "use strict';5_ÐÉËÊÿÿÿÿPƒœïõ%5_ÐÊÌË ÿÿÿÿPƒœòõ 5_ÐËÍÌ ÿÿÿÿPƒœòõ%var output = Name()5_ÐÌÎÍ ÿÿÿÿPƒœôõ%var output = ""5_ÐÍÏÎ ÿÿÿÿPƒœùõ%var output = "output@"5_ÐÎÐÏ!ÿÿÿÿPƒõ "%A accumulate(append(queue[queued], queue[output]), next, initial)5_ÐÏÑÐ ÿÿÿÿPƒ¢=õ %#var emit = require('./signal').emit5_ÐÐÒÑ !ÿÿÿÿPƒ¢?õ %!var emit = require('./emit').emit5_ÐÑÓÒ ÿÿÿÿPƒ¢@õ %var emit = require('./emit')5_ÐÒÔÓ ÿÿÿÿPƒ¢Cõ %var emit = require('./emit")5_ÐÓÕÔÿÿÿÿPˆJõ'/* vim:set ts=2 sw=2 sts=2 expandtab */5_ÐÔÖÕÿÿÿÿPˆJŽõM/*jshint asi: true undef: true es5: true node: true browser: true devel: true5_ÐÕ×Ö ÿÿÿÿPˆJŽõ9 forin: true latedef: false globalstrict: true */5_ÐÖØ×ÿÿÿÿPˆJõ5_Ð×ÙØÿÿÿÿPŒ+çõ!/ var value = convert(target, queue.accumulate)5_ÐØÚÙ ÿÿÿÿPßƒõ "õ !5_ÐÙÛÚÿÿÿÿPßŽõ "function Queue()5_ÐÚÜÛÿÿÿÿPßŽõ "function Queue() {}5_ÐÛÝÜÿÿÿÿPßõ#5_ÐÜÞÝÿÿÿÿPß¡õ % õ $5_ÐÝßÞÿÿÿÿPß§õ % this[]5_ÐÞàßÿÿÿÿPß¨õ % this[output]5_ÐßáàÿÿÿÿPß«õ& õ%5_Ðàâá ÿÿÿÿPßõ& this[]5_Ðáãâ ÿÿÿÿPß¯õ& this[queued]5_ÐâäãÿÿÿÿPß±õ &function Queue() {5_ÐãåäÿÿÿÿPß¹õaccumulate.defineõ'õ&5_ÐäæåÿÿÿÿPßÀõ(accumulate.define()5_Ðåçæÿÿÿÿ#&vPßÌõ(accumulate.define(Queue, )5_Ðæèçÿÿÿÿ'*vPßÍõ,})õ,)5_Ðçéèÿÿÿÿ&)vPßôõ+ queued = null5_Ðèêéÿÿÿÿ&)vPßý õ+ queue[queued = null5_ÐéëêÿÿÿÿvPàõ+9accumulate.define(Queue, function(queue, next, initial) {A accumulate(concat(queue[queued], queue[output]), next, initial) queue[queued] = null})5_Ðêìë#ÿÿÿÿ#&vPà !õ"'%queue.accumulate = õ"$(3queue.accumulate = function(queue, next, initial) {A accumulate(concat(queue[queued], queue[output]), next, initial) queued = null}5_ÐëíìÿÿÿÿvPàõ(accumulate.define(Queue, )5_ÐìîíÿÿÿÿvPàõ5_ÐíïîÿÿÿÿvPà"õ5_ÐîðïÿÿÿÿvPàõ'õ&5_Ðïñð&ÿÿÿÿvPà õ&((õ&('5_Ððòñ'ÿÿÿÿvPà"õ&((accumulate.define(Queue, )5_Ðñóò')ÿÿÿÿvPà&õ&)()accumulate.define(Queue, queue.accumulate5_Ðòôó(ÿÿÿÿvPà)õ')) em5_Ðóõô(ÿÿÿÿvPà,õ')) emit.define()5_Ðôöõ(ÿÿÿÿvPà2#õ(*)5_Ðõ÷öÿÿÿÿvPà=$õ"var convert = require("./convert")5_Ðöø÷ÿÿÿÿvPà@õ* õ)5_Ð÷ùøÿÿÿÿvPàF%õ* return new Queue()5_ÐøúùÿÿÿÿvPàJõ- var value = convert(null, queue.accumulate)5_ÐùûúÿÿÿÿvPàJõ# emit.implement(value, queue.emit)5_ÐúüûÿÿÿÿvPàKõ value[output] = target5_ÐûýüÿÿÿÿvPàKõ value[queued] = []5_ÐüþýÿÿÿÿvPàL&õ return value5_Ðýþ#ÿÿÿÿP®§",õ"#emit.define(Queue, queue.emit)5_ÐþÿÿÿÿÿvP®§ï-õvar emit = require("./emit")5_ÐÿÿÿÿvP®¨õ%queue.emit = function(queue, value) {5_ÐÿÿÿÿvP®¨õ if (isDrained(queue))5_ÐÿÿÿÿvP®¨õ emit(queue[output], value)5_ÐÿÿÿÿvP®¨õ else queue[queued].push(value)5_ÐÿÿÿÿvP®¨õ return queue5_ÐÿÿÿÿvP®¨õ}5_ÐÿÿÿÿvP®¨.õ function isDrained(queue) {5_ÐÿÿÿÿvP®¨.õ return !queue[queued]5_ÐÿÿÿÿvP®¨/õ }5_Ð ÿÿÿÿvP®¨0õ 5_Ð! ÿÿÿÿvP®¨2õ"var output = "output@" + module.id5_Ð "!ÿÿÿÿvP®¨7õ"var source = "output@" + module.id5_Ð!#" ÿÿÿÿvP®¨:.õ this[output] = target5_Ð"$#/ÿÿÿÿvP®¨LõA accumulate(concat(queue[queued], queue[output]), next, initial)5_Ð#%$.ÿÿÿÿvP®¨P/õ@ accumulate(concat(queue[queued], queue[queue]), next, initial)5_Ð$&%/ÿÿÿÿvP®¨RõA accumulate(concat(queue[queued], queue[queued]), next, initial)5_Ð%'&+ÿÿÿÿvP®¨T0õ< accumulate(concat(queue[queued], queue[o]), next, initial)5_Ð&('/ÿÿÿÿvP®¨X1õ@ accumulate(concat(queue[queued], queue[source), next, initial)5_Ð')(ÿÿÿÿvP®©Qõ function bufferõõ5_Ð(*)ÿÿÿÿvP®©Yõ function buffer()5_Ð)+*ÿÿÿÿvP®©[õ function buffer(queue)5_Ð*,+ÿÿÿÿvP®©\õ function buffer(queue) {}5_Ð+-,ÿÿÿÿvP®©mõ5_Ð,.-ÿÿÿÿvP®©rõ5_Ð-/.ÿÿÿÿvP®©õ function buffer(queue) {5_Ð.0/ÿÿÿÿvP®©®õ 5_Ð/10ÿÿÿÿvP®©®õ }5_Ð021ÿÿÿÿvP®©¯õ 5_Ð132ÿÿÿÿvP®©ºõ õ 5_Ð243ÿÿÿÿvP®©Åõ5_Ð354ÿÿÿÿvP®©Åõ5_Ð465ÿÿÿÿvP®©Æõõ5_Ð576ÿÿÿÿvP®©Èõ accumulate5_Ð687ÿÿÿÿvP®©Óõ return new Queue(target)5_Ð798ÿÿÿÿvP®©×õ õ5_Ð8:9 ÿÿÿÿvP®©Øõ accumulate()5_Ð9;:ÿÿÿÿvP®©àõ accumulate(target, function())5_Ð:<;!ÿÿÿÿvP®©áõ# accumulate(target, function() {})5_Ð;=<ÿÿÿÿvP®ªõ! accumulate(target, function() {5_Ð<>=)ÿÿÿÿvP®ªõ õ5_Ð=?> ÿÿÿÿvP®ªõ if ()5_Ð>@?ÿÿÿÿvP®ª#õ if ()5_Ð?A@ÿÿÿÿvP®ª$õ if (value[])5_Ð@BAÿÿÿÿvP®ª&õ if (value[next])5_ÐACBÿÿÿÿvP®ª)õ õ5_ÐBDCÿÿÿÿvP®ª/õ var next = value[]5_ÐCEDÿÿÿÿvP®ª3õ õ5_ÐDFE ÿÿÿÿvP®ª4õ next()5_ÐEGF*ÿÿÿÿvP®ª:õ- accumulate(target, function(value, state) {5_ÐFHGÿÿÿÿvP®ªdõ if (value[reducer])5_ÐGIHÿÿÿÿvP®ªjõ var next = value[reducer]5_ÐHJIÿÿÿÿvP®ªkõ value[reducer]5_ÐIKJÿÿÿÿvP®ªqõ value.reducer()5_ÐJLKÿÿÿÿvP®ªxõ function enqueueõõ5_ÐKMLÿÿÿÿvP®ªõ function enqueue()5_ÐLNMÿÿÿÿvP®ªˆõ function enqueue(queue, value)5_ÐMON ÿÿÿÿvP®ª‰õ !function enqueue(queue, value) {}5_ÐNPOÿÿÿÿvP®ªõ ! function enqueue(queue, value) {5_ÐOQP$ÿÿÿÿvP®ª£2õ !'function enqueue(queue, value, start) {5_ÐPRQ$ÿÿÿÿvP®ªÇõ !'function enqueue(queue, value, state) {5_ÐQSR%ÿÿÿÿvP®ªÍõ" õ!5_ÐRTSÿÿÿÿvP®ªÏõ" if ()5_ÐSUTÿÿÿÿvP®ª×õ" if (queue[])5_ÐTVUÿÿÿÿvP®ªÙõ" if (queue[queued])5_ÐUWVÿÿÿÿvP®ªÜõ" if (queue[queued].push())5_ÐVXWÿÿÿÿvP®ªàõ# õ"5_ÐWYXÿÿÿÿvP®ªåõ #)function enqueue(queue, value, initial) {5_ÐXZY ÿÿÿÿvP®ªçõ $õ #5_ÐY[ZÿÿÿÿvP®ªêõ accumulate5_ÐZ\[ÿÿÿÿvP®ªìõ #,function accumulate(queue, value, initial) {5_Ð[]\ÿÿÿÿvP®ªïõ k5_Ð\^]&ÿÿÿÿvP®« õ"& accumulate(target, function(value) {5_Ð]_^ÿÿÿÿvP®«%õ" accumulate(target, queue, ta5_Ð^`_ÿÿÿÿvP®«4õ" accumulate(target, enqueue, 5_Ð_a`ÿÿÿÿvP®«8õ value.reducer(value)5_Ð`baÿÿÿÿvP®«9õ next(value)5_ÐacbÿÿÿÿvP®«9õ })5_ÐbdcÿÿÿÿvP®«Gõ )function consume(queue, value, initial) {5_ÐcedÿÿÿÿvP®«Mõ )function enqueue(queue, value, initial) {5_ÐdfeÿÿÿÿvP®«Nõ "function enqueue(value, initial) {5_ÐegfÿÿÿÿvP®«Qõ if (queue[queued].push(value))5_ÐfhgÿÿÿÿvP®«Rõ õ5_ÐgihÿÿÿÿvP®«Võ if ()5_ÐhjiÿÿÿÿvP®«[õ if (queue)5_ÐikjÿÿÿÿvP®«[õ if (queue[])5_ÐjlkÿÿÿÿvP®«põ õ 5_ÐkmlÿÿÿÿvP®«xõ var reducer = ""5_ÐlnmÿÿÿÿvP®«{õ var reducer = "reducer@"5_ÐmonÿÿÿÿvP®«õ if (queue[reducer])5_ÐnpoÿÿÿÿvP®«†õ !õ 5_Ðoqp ÿÿÿÿvP®«Šõ !var state = ""5_Ðprq ÿÿÿÿvP®«õ !var state = "state@"5_ÐqsrÿÿÿÿvP®«®õ! if (queue[reducer]) 5_ÐrtsÿÿÿÿvP®«¯õ! if (queue[reducer]) queue[]5_Ðsut"ÿÿÿÿvP®«°õ!" if (queue[reducer]) queue[state]5_Ðtvu+ÿÿÿÿvP®«¶õ!, if (queue[reducer]) queue[state] = queue[]5_Ðuwv3ÿÿÿÿvP®«¸õ!3 if (queue[reducer]) queue[state] = queue[reducer]5_Ðvxw4ÿÿÿÿvP®«¹õ!5 if (queue[reducer]) queue[state] = queue[reducer]()5_ÐwyxAÿÿÿÿvP®«¼õ!C if (queue[reducer]) queue[state] = queue[reducer](value, queue[])5_ÐxzyEÿÿÿÿvP®«Àõ" õ!5_Ðy{z ÿÿÿÿvP®«Êõ" else queue[]5_Ðz|{ÿÿÿÿvP®«Ìõ" else queue[queued]5_Ð{}|ÿÿÿÿvP®«Íõ" else queue[queued].push()5_Ð|~}ÿÿÿÿvP®«Öõ# õ"5_Ð}~ ÿÿÿÿvP®«üõ$ õ#5_Ð~€ÿÿÿÿvP®«þõ$ if ()5_Ð€ ÿÿÿÿvP®¬õ$ if (queued[])5_Ð€‚ÿÿÿÿvP®¬13õ if (queued[reducer])5_Ðƒ‚ÿÿÿÿvP®¬8õ#H if (queue[reducer]) queue[state] = queue[reducer](value, queue[state])5_Ð‚„ƒÿÿÿÿvP®¬9õ% õ$5_Ðƒ…„ÿÿÿÿvP®¬;õ& õ%5_Ð„†…ÿÿÿÿvP®¬=õ' õ&5_Ð…‡†ÿÿÿÿvP®¬Aõ' var result = $ queue[reducer](value, queue[state])õ'6 queue[state] = queue[reducer](value, queue[state])5_Ð†ˆ‡ÿÿÿÿvP®¬Cõ' õ&5_Ð‡‰ˆÿÿÿÿvP®¬Eõ' if ()5_ÐˆŠ‰ÿÿÿÿvP®¬Gõ' if (isReduced())5_Ð‰‹ŠÿÿÿÿvP®¬Kõ' if (isReduced(result))5_ÐŠŒ‹ÿÿÿÿvP®¬Nõ' if (isReduced(result)) 5_Ð‹ŒÿÿÿÿvP®¬^õ' if 5_ÐŒŽÿÿÿÿvP®¬_õ' 5_ÐŽ ÿÿÿÿvP®¬cõ' elese 5_ÐŽ ÿÿÿÿvP®¬iõ' else 5_Ð‘ ÿÿÿÿvP®¬mõ' queue[]5_Ð’‘ÿÿÿÿvP®¬nõ' queue[reducer]5_Ð‘“’ÿÿÿÿvP®¬uõ'( if (isReduced(result)) return result5_Ð’”“+ÿÿÿÿvP®¬}õ'9 if (isReduced(result) || value === end) return result5_Ð“•”-ÿÿÿÿvP®¬}õ'< if (isReduced(result) || value === end) {} return result5_Ð”–•ÿÿÿÿvP®¬õ( } return result5_Ð•—–ÿÿÿÿvP®¬‚õ) õ(5_Ð–˜—ÿÿÿÿvP®¬…õ) queue[]5_Ð—™˜ÿÿÿÿvP®¬‡õ) queue[state]5_Ð˜š™ÿÿÿÿvP®¬‰õ) queue[state] = void()5_Ð™›š"ÿÿÿÿvP®¬«õ"$* õ"$)5_Ðšœ›#ÿÿÿÿvP®¬õ"$* if ()5_Ð›œ#ÿÿÿÿvP®¬µõ"$* if (queue.ended)5_Ðœž#ÿÿÿÿvP®¬¹õ"$* if (queue.ended) accumulate()5_ÐŸž#$ÿÿÿÿvP®¬½õ"$*& if (queue.ended) accumulate(queue[])5_Ðž Ÿ#+ÿÿÿÿvP®¬Äõ"$*, if (queue.ended) accumulate(queue[queued])5_ÐŸ¡ #3ÿÿÿÿvP®¬Ïõ"$*4 if (queue.ended) accumulate(queue[queued].shift())5_Ð ¢¡"2ÿÿÿÿvP®¬Ùõ"$+ õ"$*5_Ð¡£¢#ÿÿÿÿvP®¬æõ"$+ var buffered = queue[]5_Ð¢¤£#ÿÿÿÿvP®¬èõ"$+ var buffered = queue[queue]5_Ð£¥¤#ÿÿÿÿvP®¬èõ#%, õ#%+5_Ð¤¦¥$ÿÿÿÿvP®¬íõ#%, queue[]5_Ð¥§¦$ÿÿÿÿvP®¬ïõ#%, queue[queued]5_Ð¦¨§$ÿÿÿÿvP®¬ñõ#%, queue[queued] = void()5_Ð§©¨$ÿÿÿÿvP®¬öõ$&- õ$&,5_Ð¨ª©%ÿÿÿÿvP®¬ùõ$&- if ()5_Ð©«ª%ÿÿÿÿvP®¬þõ$&- if (queue.ended)5_Ðª¬«%ÿÿÿÿvP®õ$&- if (queue.ended) accumulate()5_Ð«¬%4ÿÿÿÿvP®õ%'. õ%'-5_Ð¬®&ÿÿÿÿvP®õ%'. else accumulate()5_Ð¯®&ÿÿÿÿvP®õ%'. else accumulate(concat())5_Ð®°¯&)ÿÿÿÿvP® õ%'., else accumulate(concat(buffered, queue[]))5_Ð¯°&1ÿÿÿÿvP®#4õ%'.2 else accumulate(concat(buffered, queue[source]))5_ÐþÿÿÿÿÿP®§&'õ5_ÐÿÿÿÿÿP®§)õ5_ÐÿÿÿÿP®§*õ5_ÐÿÿÿÿP®§*õ5_ÐÿÿÿÿP®§+õ5_ÐÿÿÿÿP®§,õ5_ÐÿÿÿÿP®§,(õ5_ÐÿÿÿÿP®§:õ 5_ÐÿÿÿÿP®§:õ 5_Ð ÿÿÿÿP®§;)õ 5_Ð ÿÿÿÿvP®§Nõ õ accumulate.define()5_Ð ÿÿÿÿvP®§Qõ accumulate.define(Queue, )5_Ð ÿÿÿÿvP®§„õ"var output = "source@" + module.id5_Ð ÿÿÿÿvP®§ˆõ"var source = "source@" + module.id5_Ð ÿÿÿÿvP®§õ this[source] = target5_ÐÿÿÿÿvP®§”õ 5_ÐÿÿÿÿvP®§•*õ 5_Ð/ÿÿÿÿvP®§š+õA accumulate(concat(queue[queued], queue[source]), next, initial)5_Ð ÿÿÿÿvP®§Œõ this[source] = []5_Ð ÿÿÿÿvP®§Yõqueue.accumulate = 5_Ð ÿÿÿÿvP®§\õ 9accumulate.define(Queue, function(queue, next, initial) {A accumulate(concat(queue[queued], queue[output]), next, initial) queue[queued] = null})5_Ð ÿÿÿÿvP®§aõ5_ÐÁÃÂ=ÿÿÿÿPƒœÒõ &5_Ð§¨ª©ÿÿÿÿ(($v$P (õ*function queue(source) {5_Ð§©¨ ÿÿÿÿ(($v$P õ*var input = Name()5_Ð†ˆŒ‡, ÿÿÿÿ00$v$P õõ,-2 õ,.3 append()5_Ð‡‰ˆ- ÿÿÿÿ00$v$P üõ,.3 append(queue[])5_ÐˆŠ‰-ÿÿÿÿ00$v$P õ,.3 append(queue[queued])5_Ð‰‹Š-ÿÿÿÿ00$v$P õ,.3 append(queue[queued], queue[])5_ÐŠ‹-ÿÿÿÿ00$v$P õ,.3" append(queue[queued], queue[ou])5_Ð_a‚`,ÿÿÿÿ$($vP Ëõ,-2 õ,.3 if ()5_Ð`ba-ÿÿÿÿ$($vP Ïõ,.3 if (isDrained())5_Ðacb-ÿÿÿÿ$($vP Ôõ,.3 if (!isDrained())5_Ðbdc-ÿÿÿÿ$($vP Öõ,.3 if (!isDrained(queue))5_Ðced-ÿÿÿÿ$($vP ×õ,.3 if (!isDrained(queue)) drain()5_Ðdme-ÿÿÿÿ$($vP Ùõ,.3% if (!isDrained(queue)) drain(queue)5_Ðenfm-ÿÿÿÿ$($vP Yõ,.32 if (!isDrained(queue)) append(queue[drain(queue)5_Ðmon-&ÿÿÿÿ$($vP Œõ,.3; if (!isDrained(queue)) append(queue[queued], drain(queue)5_Ðnpo-/ÿÿÿÿ$($vP –õ,.3I if (!isDrained(queue)) append(queue[queued], queue[output])drain(queue)5_Ðoqp-ÿÿÿÿ$($vP ¤õ,.3 if (!isDrained(queue))> accumulateappend(queue[queued], queue[output])drain(queue)õ-/? accumulate(append(queue[queued], queue[output])drain(queue)5_Ðprq.?ÿÿÿÿ$($vP §õ-/45 accumulate(append(queue[queued], queue[output]), 5_Ðqsr.5ÿÿÿÿ$($vP õ-/4C accumulate(append(queue[queued], queue[output]), next, initial)5_Ðrts-ÿÿÿÿ$($vP ·õ,.4 if (!isDrained(queue)) {}5_Ðsut-ÿÿÿÿ$($vP ¸õ,.4 if (!isDrained(queue)) {5_Ðtvu.ÿÿÿÿ$($vP ¹õ./4 õ.05 }5_Ðuwv6ÿÿÿÿ$($vP Áõ56 enqueue = channels.enqueue, close = channels.close5_Ðvxw8ÿÿÿÿ$($vP Äõ 5N convert = core.convert, accumulate = core.accumulate, append = core.append5_Ðwyx-ÿÿÿÿ$($vP Öõ-.5 õ-/6 queue5_Ðxzy.ÿÿÿÿ$($vP Úõ-/5_Ðy{z.ÿÿÿÿ$($vP Ûõ./5 õ.06 queue[]5_Ðz|{/ ÿÿÿÿ$($vP Ýõ.06 queue[queued]5_Ð{}|/ÿÿÿÿ$($vP ßõ.06 queue[queued] = null5_Ð|~}0ÿÿÿÿ$($vP äõ/16 } else {}5_Ð}~0ÿÿÿÿ$($vP åõ/16 } else {5_Ð~€1ÿÿÿÿ$($vP æõ026, accumulate(queue[output], next, initial)5_Ð€1ÿÿÿÿ$($vP çõ126 õ137 }5_Ð€3ÿÿÿÿ$($vP îõ245_Ðegmf/ÿÿÿÿ$($vP Ûýõ.05_Ðfig8ÿÿÿÿ$($vP ÿõ 2N convert = core.convert, accumulate = core.accumulate, append = core.append5_Ðgjhi'ÿÿÿÿ$($vP -õ&(2 if (isDrained(queue)) append()5_Ðikj'ÿÿÿÿ$($vP 2õ&(2' if (isDrained(queue)) append(value[])5_Ðjlk'%ÿÿÿÿ$($vP 3õ&(2, if (isDrained(queue)) append(value[queue])5_Ðkl'+ÿÿÿÿ$($vP 5õ&(25 if (isDrained(queue)) append(value[queue], queue[])5_Ðgih'ÿÿÿÿ$($vP &õ&(2 if (isDrained(queue)) append()5_ÐTUYX/ÿÿÿÿP 2õ/05 õ/16 isDrained()5_ÐTVXU/ÿÿÿÿP õ.05_ÐUWV0 ÿÿÿÿP õ/14 if (!isDrained()) drain(queue)5_ÐVW0ÿÿÿÿP õ/14% if (!isDrained(queue)) drain(queue)5_Ð!#"6ÿÿÿÿ%%vPôèõ57C0queue.enqueue = function enqueue(queue, value) {5_Ðýÿþÿÿÿÿ'v'PqõF return isOpen(queue) && 5_Ðþÿ ÿÿÿÿ'v'PuõF, return !queue[queued] && isOpen(queue) && 5_Ðÿ,ÿÿÿÿ'v'PxàõF( return !queue[queued] && isOpen(queue)5_Ðó÷ôøö*ÿÿÿÿ))vPÜõ)+5_Ðö÷*ÿÿÿÿ))vPÝÜõ)+5_Ðóõöô*ÿÿÿÿ))vP»õ)+5_Ðôõ*ÿÿÿÿ))vP»Úõ)+5_ÐÈÊáÉ!ÿÿÿÿ55vPzõ!"A õ!#B Object.create()5_ÐÉÌÊ"ÿÿÿÿ55vP‚õ!#B Object.create(channel)5_ÐÊÍËÌ"ÿÿÿÿ55vPŽõ!#B% var queued = Object.create(channel)5_ÐÌÎÍ"ÿÿÿÿ55vP‘õ!#B$ var queue = Object.create(channel)5_ÐÍÏÎ#ÿÿÿÿ55vP“õ"$B queued[queued] = items5_ÐÎÐÏ#ÿÿÿÿ55vP”õ"$B queue[queued] = items5_ÐÏÑÐ$ÿÿÿÿ$$vP•õ#%B queue[target] = channel5_ÐÐÒÑ$ÿÿÿÿ$$vPœõ#%B 5_ÐÑÓÒ"ÿÿÿÿ%%vPõ"#B õ"$C queue[target] = channel5_ÐÒÔÓ%ÿÿÿÿ%%vPžÐõ$&C return queue5_ÐÓÕÔ' ÿÿÿÿ%%vP¨õ'(C õ')D dispose()5_ÐÔÖÕ( ÿÿÿÿ%%vP«õ')D dispose(queue.target)5_ÐÕ×Ö(ÿÿÿÿ%%vP®õ')D dispose(queue[target)5_ÐÖØ×(ÿÿÿÿ%%vP°õ')D dispose(queue[target])5_Ð×ÙØ*ÿÿÿÿ%%vP²õ)+D queue[queue] = null5_ÐØÚÙ* ÿÿÿÿ%%vPµÑõ)+D queue[queued] = null5_ÐÙÛÚ(ÿÿÿÿ%%vP¾Òõ')5_ÐÚÜÛ9ÿÿÿÿ%%vPõ8:5_ÐÛÝÜ9ÿÿÿÿ%%vPõ8:5_ÐÜÞÝ9ÿÿÿÿ%%vPõ8:5_ÐÝßÞ9ÿÿÿÿ%%vPõ8:5_ÐÞàß9ÿÿÿÿ%%vPõ8:5_Ðßà9ÿÿÿÿ"% v PÓõ8:5_ÐÊÌË"ÿÿÿÿ55vP†õ!#B Object.create(target)5_ÐUW_V$ÿÿÿÿ"vP÷‰õ.&dispose.define(Queue, function(self) {5_ÐVXWÿÿÿÿ"vP÷õ. self[target] = null5_ÐWYXÿÿÿÿ"vP÷‘õ. self[target] = null5_ÐXZY $ÿÿÿÿ"vP÷”õ!.-enqueue.define(Queue, function(self, value) {5_ÐY[Z!"ÿÿÿÿ"vP÷•õ ".1 if (isOpen(queue)) enqueue(self[target], value)5_ÐZ\["ÿÿÿÿ"vP÷™õ!#. else self[queued].push(value)5_Ð[]\!ÿÿÿÿ"vP÷›õ ".0 if (isOpen(self)) enqueue(self[target], value)5_Ð\^]%ÿÿÿÿ"vP÷žõ$&.1 if (isClosed(self)) return next(end(), initial)5_Ð]^$'ÿÿÿÿ"vP÷¡õ#%.8accumulate.define(Queue, function(self, next, initial) {5_Ð³µ¶´:ÿÿÿÿ22vO·Æîõ9;}exports.Closable = Closable5_Ð´µ2ÿÿÿÿO·Çõ13var Closeable = protocol({õ57var close = Closeable.closeõ68var closed = Closeable.closedõ9;exports.Closeable = Closeableõik Closeable, {5_Ð\_]j^2ÿÿÿÿ22vO·Âûõ13rvar Closable = protocol({5_Ð^`_3ÿÿÿÿ22vO·Ãõ24r close: [ protocol ]5_Ð_a`2ÿÿÿÿ22vO·Ãõ23r õ24s isOpen: []5_Ð`ba3ÿÿÿÿ22vO·Ãõ24s isOpen: [ protocol ]5_Ðacb3ÿÿÿÿ22vO·Ãõ24s isOpen: [ protocol ],5_Ðbdc6ÿÿÿÿ22vO·Ãõ57svar close = Endable.end5_Ðced6ÿÿÿÿ22vO·Ãõ57svar close = Closable.end5_Ðdfe6ÿÿÿÿ22vO·Ãõ57svar close = Closable.close5_Ðegf7ÿÿÿÿ22vO·Ã"õ68sexports.close = end5_Ðfhg7ÿÿÿÿ22vO·Ã$õ68sexports.close = close5_Ðgih8ÿÿÿÿ22vO·Ã(õ79sexports.Closable = Endable5_Ðhi8ÿÿÿÿ22vO·Ã*}õ79sexports.Closable = Closable5_Ð\^]Dÿÿÿÿll vO·ÂÒõDEr õDFs var queued = queue.queued5_ÐùûúH ÿÿÿÿFCFvO·»$õGIa( var reducer = reducers.shift()5_ÐÓÕÙÔCÿÿÿÿ66vO·¹áõBD5_ÐÔÖÕCÿÿÿÿ66vO·¹áõBD5_ÐÕ×ÖCÿÿÿÿ66vO·¹âõBD5_ÐÖØ×Cÿÿÿÿ66vO·¹ãõBD5_Ð×ØCÿÿÿÿ66vO·¹éõBDb2 while (reducers.length && reducers.length) {5çª