VimŸUnDoå~±}Ú´|•š‡µ1O·mm„S`p×)8a<¾@õA _stream.next = nullUUUUNg˜‹ _ÐÿÿÿÿNO¡tõ5_Ð ÿÿÿÿNO¡Žõ function 5_ÐÿÿÿÿNO¡‘õfunction queue()5_ÐÿÿÿÿNO¡‘õfunction queue() {}5_ÐÿÿÿÿNO¡¤õ õ5_ÐÿÿÿÿNO¡®õ function stream()5_ÐÿÿÿÿNO¡µõ function stream(next, stop)5_Ð ÿÿÿÿNO¡µõ function stream(next, stop) {}5_Ð ÿÿÿÿNO¡èõ5_Ð ÿÿÿÿNO¡êõ function stream(next, stop) {5_Ð ÿÿÿÿNO¡õõ }5_Ð ÿÿÿÿNO¡÷õ }, 5_Ð ÿÿÿÿNO¡øõ }, ''5_Ð ÿÿÿÿNO¡úõ }, {}5_ÐÿÿÿÿNO¢õ }, { valueOf: {}}5_Ð#ÿÿÿÿNO¢ õ& }, { valueOf: { value: function ()}}5_Ð+ÿÿÿÿNO¢õ- }, { valueOf: { value: function valueOf()}}5_Ð-ÿÿÿÿNO¢õ0 }, { valueOf: { value: function valueOf() {}}}5_ÐÿÿÿÿNO¢õ }}}5_ÐÿÿÿÿNO¢õ }}5_ÐÿÿÿÿNO¢õ }} }5_ÐÿÿÿÿNO¢ õ }} })5_ÐÿÿÿÿNO¢%õ7 Object.defineProperties(function stream(next, stop) {5_ÐÿÿÿÿNO¢(õ? returns Object.defineProperties(function stream(next, stop) {5_Ð ÿÿÿÿNO¢,õ õ5_ÐÿÿÿÿNO¢bõfunction queue() {5_ÐÿÿÿÿNO¢cõ5_ÐÿÿÿÿNO¢hõfunction valueOf()5_ÐÿÿÿÿNO¢hõfunction valueOf() {}5_ÐÿÿÿÿNO¢lõ function valueOf() {5_Ð ÿÿÿÿNO¢mõ 5_Ð! ÿÿÿÿNO¢oõ õ 5_Ð "!ÿÿÿÿNO¢‡õ value === this5_Ð!#"ÿÿÿÿNO¢Êõfunction valueOf(value) {5_Ð"$#ÿÿÿÿNO¢Ëõ value === this ? 5_Ð#%$ÿÿÿÿNO¢Ëõ}5_Ð$&%ÿÿÿÿNO¢Ìõ5_Ð%'&ÿÿÿÿNO¢Îõ 5_Ð&('*ÿÿÿÿNO¢Ôõ- }, { valueOf: { value: function valueOf() {5_Ð')(ÿÿÿÿNO¢Öõ this === value ? 5_Ð(*)>ÿÿÿÿNO¢çõ? this === value ? buffer : Function.prototype.valueOf.call()5_Ð)+*ÿÿÿÿNO¢óõC this === value ? buffer : Function.prototype.valueOf.call(this)5_Ð*,+ÿÿÿÿNO¢ÿõ õ5_Ð+-,ÿÿÿÿNO£)õ5_Ð,.- ÿÿÿÿNO£Žõ while 5_Ð-/.ÿÿÿÿNO©Sõ õõ5_Ð.0/ÿÿÿÿNO©kõ"õ !5_Ð/10 ÿÿÿÿNO©rõ #function enqueue5_Ð021 ÿÿÿÿNO©ƒõ #function enqueue()5_Ð132 ÿÿÿÿNO©†õ #function enqueue(queue)5_Ð243 ÿÿÿÿNO©‡õ #function enqueue(queue) {}5_Ð354 ÿÿÿÿNO©‰õ % õ $5_Ð465ÿÿÿÿNO©õ % queue()5_Ð576ÿÿÿÿNO©’õ % queue.valueOf()5_Ð687ÿÿÿÿNO©õ % queue.valueOf(queue)5_Ð798ÿÿÿÿNO©³õ % queue.valueOf(queue).push5_Ð8:96ÿÿÿÿNO©¿õ %6 Array.prototype.push.apply(queue.valueOf(queue).push5_Ð9;:3ÿÿÿÿNO©Ñõ %3 Array.prototype.push.apply(queue.valueOf(queue), 5_Ð:<;IÿÿÿÿNO©Úõ %J Array.prototype.push.apply(queue.valueOf(queue), Array.prototype.slice()5_Ð;=<ÿÿÿÿNO©âõ%function queue() {5_Ð<>=ÿÿÿÿNO©åõ&5_Ð=?>ÿÿÿÿNO©íõ&5_Ð>@?ÿÿÿÿNO©îõ(õ'5_Ð?A@ÿÿÿÿNO©üõ (V Array.prototype.push.apply(queue.valueOf(queue), Array.prototype.slice(arguments, 1)5_Ð@BA3ÿÿÿÿNOªõ (F push.apply(queue.valueOf(queue), Array.prototype.slice(arguments, 1)5_ÐACB(ÿÿÿÿNOªõ (6 push.apply(queue.valueOf(queue), slice(arguments, 1)5_ÐBDC;ÿÿÿÿNOªõ (; push.apply(queue.valueOf(queue), slice.call(arguments, 1)5_ÐCEDÿÿÿÿNOªõfunction dequeueõ)õ(5_ÐDFEÿÿÿÿNOª!õfunction dequeue()5_ÐEGFÿÿÿÿNOª"õ5_ÐFHGÿÿÿÿNOªrõ( var buffer = []5_ÐGIHÿÿÿÿNOª|õ function stopõ)õ(5_ÐHJIÿÿÿÿNOªõ*function stop()5_ÐIKJÿÿÿÿNOªƒõ*function stop(queue)5_ÐJLKÿÿÿÿNOªƒõ*function stop(queue) {}5_ÐKMLÿÿÿÿNOª†õ+function stop(queue) {5_ÐLNMÿÿÿÿNOªŠõ, õ+5_ÐMONÿÿÿÿNOª¥õ var BUFFER = õ-õ,5_ÐNPO ÿÿÿÿNOª±õ/õ.5_ÐOQP !ÿÿÿÿNOªÉõ /> return Object.defineProperties(function stream(next, stop) {5_ÐPRQ ÿÿÿÿNOªÌõ while ()5_ÐQSR ÿÿÿÿNOªÌõ 2 }, { valueOf: { value: function valueOf(value) {5_ÐRTS ÿÿÿÿNOªÍõ J return this === value ? buffer : Function.prototype.valueOf.call(this)5_ÐSUT ÿÿÿÿNOªÍõ }}})5_ÐTVU ÿÿÿÿNOªÏõ , õ +5_ÐUWV ÿÿÿÿNOªÕõ - õ ,5_ÐVXW ÿÿÿÿNOª×õ - if ()5_ÐWYX ÿÿÿÿNOªÚõ - if (next)5_ÐXZYÿÿÿÿNOªàõ - var buffer = [], reson5_ÐY[Z!ÿÿÿÿNOªçõ -! var buffer = [], onNext, onStop5_ÐZ\[ ÿÿÿÿNOªöõ - if (next ===5_Ð[]\ ÿÿÿÿNO«õ - if (next === ENQUEUE)5_Ð\^] ,ÿÿÿÿNO«(õ -- if (next === ENQUEUE) buffer.push.apply()5_Ð]_^ 8ÿÿÿÿNO«0õ . õ -5_Ð^`_ ÿÿÿÿNO«4õ . else if ()5_Ð_a`ÿÿÿÿNO«7õ . else if (next)5_Ð`baÿÿÿÿNO«Dõ/ õ.5_Ðacb ÿÿÿÿNO«Nõ/ stream.valueOf = function()5_Ðbdc $ÿÿÿÿNO«Põ/% stream.valueOf = function valueOf()5_Ðced &ÿÿÿÿNO«Võ/& stream.valueOf = function valueOf($)5_Ðdfe (ÿÿÿÿNO«Wõ/) stream.valueOf = function valueOf($) {}5_Ðegf ÿÿÿÿNO«Yõ 1õ 05_ÐfhgÿÿÿÿNO«^õ 1 if ()5_ÐgihÿÿÿÿNO«dõ 1 if ($ === ENQUEUE)5_Ðhji(ÿÿÿÿNO«xõ 1( if ($ === ENQUEUE) onNext ? onNext()5_Ðikj"ÿÿÿÿNO«õ 1$ if ($ === ENQUEUE) buffer.push()5_ÐjlkÿÿÿÿNO«†õ 1* if ($ === ENQUEUE) buffer.push.apply()5_Ðknl"ÿÿÿÿNO«ˆõ 1# if ($ === ENQUEUE) push.apply()5_Ðlomn %ÿÿÿÿNO«”õ1( stream.valueOf = function valueOf($) {5_Ðnpo*ÿÿÿÿNO«›õ 1+ if ($ === ENQUEUE) push.apply(buffer, )5_Ðoqp %ÿÿÿÿNO«¢õ1, stream.valueOf = function valueOf($, $2) {5_Ðprq ÿÿÿÿNO«¦õ 1- if ($ === ENQUEUE) push.apply(buffer, $2)5_Ðqsr ÿÿÿÿNO«©õ2 õ15_ÐrtsÿÿÿÿNO«¬õ2 if ()5_ÐsutÿÿÿÿNO«³õ2 if ($2 === STOP)5_ÐtvuÿÿÿÿNO«Âõ3 õ25_ÐuxvÿÿÿÿNO«Åõ3 if ($2 === STOP) reason = $25_Ðvywx ÿÿÿÿNO«Üõ 4 õ 35_ÐxzyÿÿÿÿvNO«ìõ4. if ($1 === ENQUEUE) push.apply(buffer, $2)5_Ðy{zÿÿÿÿvNO«îõ 4 return 5_Ðz|{ ÿÿÿÿ v NO«ôõ4 if () push.apply(buffer, $2)5_Ð{}|ÿÿÿÿ v NO«õõ 4 return $1 === ENQUEUE ? 5_Ð|~}#ÿÿÿÿ v NO«ùõ 4$ return $1 === ENQUEUE ? update()5_Ð}~:ÿÿÿÿ v NO«ûõ 4: return $1 === ENQUEUE ? update(push.apply(buffer, $2))5_Ð~€ ÿÿÿÿ vNO¬õ5% else if ($2 === STOP) reason = $25_Ð€ ÿÿÿÿ vNO¬õ5 5_Ð€‚ ÿÿÿÿ vNO¬õ5! $2 === STOP ? update()5_Ðƒ‚)ÿÿÿÿ vNO¬õ5* $2 === STOP ? update(reason = )5_Ð‚„ƒ+ÿÿÿÿ vNO¬õ5, $2 === STOP ? update(reason = $2)5_Ðƒ…„#ÿÿÿÿ vNO¬(õ 5< return $1 === ENQUEUE ? update(push.apply(buffer, $2)) :5_Ð„†…;ÿÿÿÿ vNO¬+õ 5= return $1 === ENQUEUE ? update((push.apply(buffer, $2)) :5_Ð…‡†ÿÿÿÿ"vNO¬/õ 5> return $1 === ENQUEUE ? update((push.apply(buffer, $2))) :5_Ð†ˆ‡4ÿÿÿÿ"vNO¬2õ 57 return $1 === ENQUEUE ? (push.apply(buffer, $2))) :5_Ð‡‰ˆ=ÿÿÿÿ"vNO¬5õ 5? return $1 === ENQUEUE ? (push.apply(buffer, $2), update() :5_ÐˆŠ‰ÿÿÿÿ"vNO¬9õ5. $2 === STOP ? update(reason = $2, )5_Ð‰‹Š!ÿÿÿÿ+!v!NO¬=õ5/ $2 === STOP ? (update(reason = $2, )5_ÐŠŒ‹ÿÿÿÿ+!v!NO¬@õ5$ $2 === STOP ? (update(, )5_Ð‹Œ@ÿÿÿÿ+!v!NO¬bõ5A $2 === STOP ? (reason = $2, stopped = true, update(, )5_ÐŒŽ?ÿÿÿÿ+!v!NO¬dõ* Function.prototype.valueOf.callõ5? $2 === STOP ? (reason = $2, stopped = true, update()5_ÐŽ+ÿÿÿÿ+!v!NO¬põ6, Function.prototype.valueOf.call()5_ÐŽÿÿÿÿ+!v!NO¬sõ if () 5_Ð‘ÿÿÿÿ+!v!NO¬tõ else if () reason = $25_Ð”‘ÿÿÿÿ+!v!NO¬tõ5_Ð‘•’”2ÿÿÿÿ+!v!NO¬‹õ32 Function.prototype.valueOf.call(stream)5_Ð”–• ÿÿÿÿ+!v!NO¬’õ 9 if (next === ENQUEUE) buffer.push.apply(buffer, stop)5_Ð•—– ÿÿÿÿ+!v!NO¬“õ else if (next === )5_Ð–˜— ÿÿÿÿ + !v!NO¬•õ 2 õ 15_Ð—™˜ÿÿÿÿ+!v!NO¬ õ 4 õ 35_Ð˜š™(ÿÿÿÿ+!v!NO¬³õ 4( var buffer = [], onNext, onStop, reson5_Ð™›š+ÿÿÿÿ1+v+NO¬¹õ 42 var buffer = [], onNext, onStop, reason, stopped5_Ðšœ›ÿÿÿÿ1+v+NO¬»õ 4+ var buffer = [], onNext, onStop, reason, 5_Ð›œ<ÿÿÿÿ1+v+NO¬Åõ 4< var buffer = [], stopped = false, onNext, onStop, reason, 5_Ðœž;ÿÿÿÿ1+v+NO¬Æõ 4; var buffer = [], stopped = false, onNext, onStop, reason,5_ÐŸž9ÿÿÿÿ1+v+NO¬Éõ 45_Ðž Ÿ ÿÿÿÿ1+v+NO¬Ïõ function updateõ55_ÐŸ¡ ÿÿÿÿ1+v+NO¬àõ 6 function update()5_Ð ¢¡ ÿÿÿÿ1+v+NO¬àõ 6 function update() {}5_Ð¡£¢ ÿÿÿÿ1+v+NO¬áõ 8 õ 75_Ð¢¤£ÿÿÿÿ1+v+NO¬æõ 8 while ()5_Ð£¥¤ÿÿÿÿ1+v+NO¬íõ 8 while (buffer.shift())5_Ð¤¦¥ÿÿÿÿ1+v+NO¬ñõ 8 while (buffer.length)5_Ð¥§¦ÿÿÿÿ1+v+NO¬øõ 8 while (buffer.length) next()5_Ð¦¨§ÿÿÿÿ1+v+NOõ 9 õ 85_Ð§©¨ÿÿÿÿ1+v+NOõ 9. while (buffer.length) next(buffer.shift())5_Ð¨ª©ÿÿÿÿ1+v+NOõ 9 stopped ? 5_Ð©«ªÿÿÿÿ1+v+NOõ 9 stopped ? onStop()5_Ðª¬«ÿÿÿÿ1+v+NOõ 9 stopped ? onStop(reason)5_Ð«¬ÿÿÿÿ1+v+NOõ 9" stopped ? onStop(reason) : nil5_Ð¬® ÿÿÿÿ1+v+NO2õ: õ95_Ð¯®ÿÿÿÿ1+v+NO3õ: if ()5_Ð®°¯ÿÿÿÿ1+v+NO?õ: onNext5_Ð¯±°ÿÿÿÿ1+v+NOAõ: if onNext5_Ð°´±ÿÿÿÿ1+v+NOBõ: if (onNext5_Ð±µ²´ÿÿÿÿ1+v+NO}õ: if (onNext) throw 5_Ð´¶µÿÿÿÿ1+v+NO€õ: if (onNext) throw new Error5_Ðµ·¶ÿÿÿÿ1+v+NOõ: if (onNext) throw Error5_Ð¶¸·ÿÿÿÿ1+v+NO„õ: if (onNext) throw Error()5_Ð·¹¸ÿÿÿÿ1+v+NO…õ: if (onNext) throw Error("")5_Ð¸º¹1ÿÿÿÿ1+v+NO‰õ:3 if (onNext) throw Error("stream is being read")5_Ð¹»º2ÿÿÿÿ1+v+NO‹õ:4 if (onNext) throw Error("stream is being read1")5_Ðº¼»2ÿÿÿÿ1+v+NOõ:4 if (onNext) throw Error("stream is being read'")5_Ð»½¼&ÿÿÿÿ1+v+NO—õ:4 if (onNext) throw Error("stream is being read!")5_Ð¼¾½Hÿÿÿÿ1+v+NO õ:J if (onNext) throw Error("stream supports one reader only being read!")5_Ð½¿¾ÿÿÿÿ1+v+NO¬õ :: var buffer = [], stopped = false, onNext, onStop, reason5_Ð¾À¿ÿÿÿÿ1+v+NO°õ :D var buffer = slice.call(), stopped = false, onNext, onStop, reason5_Ð¿ÁÀÿÿÿÿ1+v+NO¿õ:var push = Array.prototype.push5_ÐÀÂÁ+ÿÿÿÿ1+v+NOÅõ*+ exports.pipe = function pipe() {5 var buffer = Array.prototype.slice.call(arguments);' var onNext, onStop, isStopped, reason return {) stream: function stream(next, stop) { onNext = next onStop = stop2 while (buffer.length) onNext(buffer.shift())# if (isStopped) onStop(reason) }," next: function next(element) { if (isStopped) return nil! if (onNext) onNext(element) else buffer.push(element) }, stop: function stop(error) { if (isStopped) return nil isStopped = true reason = error if (onStop) onStop(reason) } }}5_ÐÁÃÂ%ÿÿÿÿ1+v+NOÊõ$&*< push.apply(queue.valueOf(queue), slice.call(arguments, 1))5_ÐÂÄÃ%#ÿÿÿÿ1+v+NOÎõ$&*> push.valueOf(queue.valueOf(queue), slice.call(arguments, 1))5_ÐÃÅÄÿÿÿÿ1+v+NOôõ* 5_ÐÄÆÅ%ÿÿÿÿ1+v+NO®õ$&*1 push.valueOf(ENQUEUE, slice.call(arguments, 1))5_ÐÅÇÆ)ÿÿÿÿ1+v+NO® õ(** queue.5_ÐÆÈÇ)ÿÿÿÿ1+v+NO®õ(** queue.valueOf()5_ÐÇÉÈ)ÿÿÿÿ1+v+NO® õ(** queue.valueOf(STOP)5_ÐÈÊÉ%ÿÿÿÿ1+v+NO®õ$&*2 queue.valueOf(ENQUEUE, slice.call(arguments, 1))5_ÐÉËÊ)ÿÿÿÿ1+v+NO®õ(** queue.valueOf(STOP, reason)5_ÐÊÌË*ÿÿÿÿ1+v+NO®"õ*õ*5_ÐËÍÌÿÿÿÿ1+v+NO®:õ-õ,5_ÐÌÎÍÿÿÿÿ1+v+NO®gõvar BUFFER = {}5_ÐÍÏÎÿÿÿÿ1+v+NO®gõ var STOP = {}5_ÐÎÐÏ&ÿÿÿÿ1+v+NO®zõ&(7 õ&(65_ÐÏÑÐ'ÿÿÿÿ1+v+NO®|õ&(7 _()5_ÐÐÒÑ'ÿÿÿÿ1+v+NO®}õ&(7 _(stream)5_ÐÑÓÒ'ÿÿÿÿ#v#NO®Œõ&(7 _(stream).buffer = 5_ÐÒÔÓ')ÿÿÿÿ#v#NO®õ')8 õ')75_ÐÓÕÔ(ÿÿÿÿ#v#NO®“õ')8 _()5_ÐÔÖÕ(ÿÿÿÿ#v#NO®—õ')8 _(stream)5_ÐÕ×Ö'ÿÿÿÿ#v#NO®¨õ&(8* _(stream).buffer = slice.call(arguments)5_ÐÖØ×(ÿÿÿÿ#v#NO®ºõ(*9 õ(*85_Ð×ÙØ)ÿÿÿÿ#v#NO®¼õ(*9 _()5_ÐØÚÙ&ÿÿÿÿ#v#NO®Êõ&(: õ&(95_ÐÙÛÚ'ÿÿÿÿ#v#NO®Óõ&(: var _stream = ()5_ÐÚÜÛ'ÿÿÿÿ#v#NO®Ôõ&(: var _stream = _()5_ÐÛÝÜ'ÿÿÿÿ#v#NO®×õ'); õ'):5_ÐÜÞÝ(ÿÿÿÿ)")6v6NO®ãõ'); _stream.buffer = 5_ÐÝßÞ)ÿÿÿÿ)")6v6NO®äõ()7 var buffer = _(stream).buffer = slice.call(arguments)5_ÐÞàß)ÿÿÿÿ)")6v6NO®çõ(*: _(stream).next 5_Ðßáà)ÿÿÿÿ)")6v6NO®éõ(*: _(stream.next 5_Ðàâá)ÿÿÿÿ)")6v6NO®éõ(*: _stream.next 5_Ðáãâ)ÿÿÿÿ)")6v6NO®ìõ() _stream.next5_Ðâäã)ÿÿÿÿ)")6v6NO®íõ() _(stream)5_Ðãåä)ÿÿÿÿ)")6v6NO®îõ()- stream.valueOf = function valueOf($1, $2) {5_Ðäæå)ÿÿÿÿ)")6v6NO®ïõ()@ return $1 === ENQUEUE ? (push.apply(buffer, $2), update()) :5_Ðåçæ)ÿÿÿÿ)")6v6NO®ïõ()B $2 === STOP ? (reason = $2, stopped = true, update()) :5_Ðæèç)ÿÿÿÿ)")6v6NO®ïõ() stream5_Ðçéè)ÿÿÿÿ)")6v6NO®ðõ() }5_Ðèêé(ÿÿÿÿ)")6v6NO®òõ(*4 õ(*35_Ðéëê(ÿÿÿÿ*"*6v6NO¯õ&(4 var _stream = _(stream)&_stream.buffer = slice.call(arguments)õ')4( _stream.buffer = slice.call(arguments)5_Ðêìëÿÿÿÿ)")6v6NO¯õM var buffer = slice.call(arguments), stopped = false, onNext, onStop, reason5_Ðëíìÿÿÿÿ("(6v6NO¯õ5_Ðìîíÿÿÿÿ'"'6v6NO¯$õ1) return stopped ? onStop(reason) : nil5_Ðíïî"ÿÿÿÿ'"'6v6NO¯*õ1/ return stopped ? _stream.stop(reason) : nil5_Ðîðïÿÿÿÿ'"'6v6NO¯.õ16 return stopped ? _stream.stop(stream.reason) : nil5_Ðïñð ÿÿÿÿ'"'6v6NO¯7õ var push = Array.prototype.push5_Ððòñ ÿÿÿÿ&"&6v6NO¯8õ !var slice = Array.prototype.slice5_Ðñóò ÿÿÿÿ%"%6v6NO¯;õ 0õ /5_Ðòôó ÿÿÿÿ&"&6v6NO¯gõ00 while (buffer.length) onNext(buffer.shift())5_Ðóõôÿÿÿÿ&"&6v6NO¯|õ1 õ05_Ðôöõÿÿÿÿ'"'6v6NO¯Šõ var next = _stream.next5_Ðõ÷ö) ÿÿÿÿ&"&6v6NO¯šõ(*09 return queue.valueOf(ENQUEUE, slice.call(arguments, 1))5_Ðöø÷)ÿÿÿÿ&"&6v6NO¯Ÿõ(*0; return _(queue.valueOf(ENQUEUE, slice.call(arguments, 1))5_Ð÷ùø) ÿÿÿÿ&"&6v6NO¯¥õ(*0C return _(queue).buffer.valueOf(ENQUEUE, slice.call(arguments, 1))5_Ðøúù)ÿÿÿÿ&"&6v6NO¯¨õ(*0H return push(_(queue).buffer.valueOf(ENQUEUE, slice.call(arguments, 1))5_Ðùûú) ÿÿÿÿ&"&6v6NO¯±õ(*08 return push(_(queue).buffer, slice.call(arguments, 1))5_Ðúüû- ÿÿÿÿ&"&6v6NO¯Áõ,.0$ return queue.valueOf(STOP, reason)5_Ðûýü-ÿÿÿÿ&"&6v6NO¯Ãõ,.0& return _(queue.valueOf(STOP, reason)5_Ðüþýÿÿÿÿ&"&6v6NO¯Ùõ 0> if (onNext) throw Error("stream supports one reader only")5_Ðýÿþ ÿÿÿÿ&"&6v6NO¯áõ!0 onNext = next5_Ðþÿ! ÿÿÿÿ&"&6v6NO¯çõ "0 onStop = stop5_Ðÿ"ÿÿÿÿ&"&6v6NO¯ïõ!#0 update()5_ÐÿÿÿÿvNO¯öõ0 function update() {6 while (buffer.length) _stream.next(buffer.shift())= return stream.stopped ? _stream.stop(stream.reason) : nil }5_ÐÿÿÿÿvNO¯÷õ 5_ÐÿÿÿÿvNO¯üõ-õ,5_ÐÿÿÿÿvNO°õ.õ-5_ÐÿÿÿÿvNO°õfunction update5_ÐÿÿÿÿvNO°õ0 }5_ÐÿÿÿÿvNO°õ05_Ð ÿÿÿÿvNO°õ16 while (buffer.length) _stream.next(buffer.shift())5_Ð ÿÿÿÿvNO° õ1= return stream.stopped ? _stream.stop(stream.reason) : nil5_Ð ÿÿÿÿvNO°õ14 while (buffer.length) _stream.next(buffer.shift())5_Ð %ÿÿÿÿvNO° õ19 while (this.buffer.length) _stream.next(buffer.shift())5_Ð 'ÿÿÿÿvNO°õ16 while (this.buffer.length) this.next(buffer.shift())5_Ð ÿÿÿÿvNO°õ2 õ15_Ð ÿÿÿÿ vNO°õ2 var buffer = this.buffer5_Ðÿÿÿÿ vNO° õ2; while (this.buffer.length) this.next(this.buffer.shift())5_Ðÿÿÿÿ vNO°"õ26 while (buffer.length) this.next(this.buffer.shift())5_Ð"ÿÿÿÿ vNO°$õ21 while (buffer.length) next(this.buffer.shift())5_Ðÿÿÿÿ vNO°'õ2; return stream.stopped ? _stream.stop(stream.reason) : nil5_Ðÿÿÿÿ vNO°0õ2function update() {5_Ðÿÿÿÿ vNO°7õ2, var buffer = this.buffer, next = this.next5_Ð*ÿÿÿÿ vNO°;õ2/ var buffer = _stream.buffer, next = this.next5_Ð ÿÿÿÿ vNO°Aõ29 return this.stopped ? _stream.stop(stream.reason) : nil5_Ðÿÿÿÿ vNO°Jõ2< return _stream.stopped ? _stream.stop(stream.reason) : nil5_Ðÿÿÿÿ vNO°Oõ2< return _stream.stopped ? _stream.stop(stream.reason) : nil5_Ð2ÿÿÿÿ vNO°\õ22 var buffer = _stream.buffer, next = _stream.next5_Ð#ÿÿÿÿ vNO°gõ2L return _stream.stopped ? _stream.stop && _stream.stop(stream.reason) : nil5_Ð+ÿÿÿÿ vNO°iõ2D return _stream.stopped ? stop && _stream.stop(stream.reason) : nil5_Ð$ÿÿÿÿ vNO°‰õ#%2 _stream.update()5_Ð$ÿÿÿÿ vNO°‹õ#%2 update()5_Ð&ÿÿÿÿ vNO°»õ%'2J var _stream = _(stream), buffer = _stream.buffer = slice.call(arguments)5_Ð &ÿÿÿÿ vNO°¾õ%'2< _(stream), buffer = _stream.buffer = slice.call(arguments)5_Ð! &ÿÿÿÿ vNO°Áõ%'2< _(stream). buffer = _stream.buffer = slice.call(arguments)5_Ð "!&ÿÿÿÿ vNO°Ãõ%'2+ _(stream)..buffer = slice.call(arguments)5_Ð!#"& ÿÿÿÿ vNO°Äõ&(3 õ&(25_Ð"'#(ÿÿÿÿ vNO°Éõ'( _stream.stopped = false5_Ð#($'%ÿÿÿÿ vNO°çõ%'3 õ%'25_Ð')(& ÿÿÿÿ vNO°ëõ%'3 _stream5_Ð(*)&ÿÿÿÿ vNO°ñõ%& _stream = _s5_Ð)+*ÿÿÿÿ vNO±õ!3 õ!25_Ð*,+ ÿÿÿÿ!!vNO±õ var _5_Ð+-,&ÿÿÿÿ vNO±õ%'2* _(stream).buffer = slice.call(arguments)5_Ð,.-&ÿÿÿÿ vNO±õ%(28 var _stream = _(stream).buffer = slice.call(arguments)5_Ð-/.'ÿÿÿÿ vNO±õ')4 õ')35_Ð.0/ ÿÿÿÿ vNO±%õ 5õ 45_Ð/10 ÿÿÿÿ!!vNO±>õ "6 õ "55_Ð021(ÿÿÿÿ""vNO±Eõ')6 var _stream = _(stream)5_Ð142#ÿÿÿÿ""vNO±Kõ"$6D if (_stream.next) throw Error("stream supports one reader only")5_Ð2534!ÿÿÿÿ""vNO±bõ 6!var slice = Array.prototype.slice5_Ð465/ÿÿÿÿ""vNO±qõ.06> return push.apply(_(queue).buffer, slice.call(arguments, 1))5_Ð576/ÿÿÿÿ""vNO±sõ/17 õ/165_Ð687.ÿÿÿÿ""vNO±zõ.08 õ.075_Ð798/ÿÿÿÿ""vNO±€õ.08 var _stream = _()5_Ð8:90ÿÿÿÿ""vNO±„õ/187 push.apply(_(queue).buffer, slice.call(arguments, 1))5_Ð9;:1 ÿÿÿÿ""vNO±Žõ028 update()5_Ð:<;4ÿÿÿÿ""vNO±”õ469 õ4685_Ð;=<5ÿÿÿÿ""vNO±™õ469 var _stream = _()5_Ð<>=5ÿÿÿÿ""vNO±šõ58: õ5795_Ð=?>4ÿÿÿÿ""vNO±«õ35;function stop(queue, reson) {5_Ð>@?7ÿÿÿÿ""vNO±õ79< õ79;5_Ð?A@8 ÿÿÿÿ""vNO±³õ79< update()5_Ð@BA9ÿÿÿÿ""vNO±µõ89' return _(queue).valueOf(STOP, reason)5_ÐACB,ÿÿÿÿ""vNO±Áõ,.<õ,.;5_ÐBDC3ÿÿÿÿ""vNO±Éõ35=õ35<5_ÐCED;ÿÿÿÿ""vNO±Ñõ;=>õ;==5_ÐDFE(ÿÿÿÿ""vNO±õõ>< return _stream.stopped ? stop && stop(stream.reason) : nil5_ÐEGFÿÿÿÿ""vNO²Lõ?õ>5_ÐFHGÿÿÿÿ##vNOÒ"õ?, while (buffer.length) next(buffer.shift())5_ÐGIH=ÿÿÿÿ##vNOÒ%õ?= return _stream.stopped ? stop && stop(_stream.reason) : nil5_ÐHJIAÿÿÿÿ##vNOÒ-õ?B return _stream.stopped ? stop && stop(_stream.reason) : update()5_ÐIKJÿÿÿÿNg˜aõ?) if (buffer.length) next(buffer.shift())5_ÐJLKÿÿÿÿNg˜fõ?1 if (next && buffer.length) next(buffer.shift())5_ÐKMLÿÿÿÿNg˜iõ@ if (next && buffer.length)5_ÐLNMÿÿÿÿNg˜jõ@ if (next && buffer.length) {}5_ÐMONÿÿÿÿNg˜kõ A õ @5_ÐNPOÿÿÿÿNg˜mõA next(buffer.shift())5_ÐOQP&ÿÿÿÿNg˜sõ!A& if (false === next(buffer.shift())5_ÐPRQ ÿÿÿÿ vNg˜…õ!C _stream.stop5_ÐQSR ÿÿÿÿ vNg˜†õ 5_ÐRTSÿÿÿÿ vNg˜‡õ B _stream.next = null5_ÐSUTÿÿÿÿ vNg˜‰õ B& _stream.stop _stream.next = null5_ÐTUÿÿÿÿ vNg˜Š õB' if (false === next(buffer.shift()))"_stream.stop = _stream.next = nullõ B( _stream.stop = _stream.next = null5_Ð243"ÿÿÿÿ""vNO±Wõ!#6 function queue(next, stop) {5_Ð#%'$ ÿÿÿÿ vNO°Ïõ !2 õ "3 var _stream = _()5_Ð$&%!ÿÿÿÿ vNO°Öõ "3 var _stream = _(stream)5_Ð%&!ÿÿÿÿ vNO°Ùõ "5_Ð±³´²ÿÿÿÿ1+v+NOxõ5_Ð²³ÿÿÿÿ1+v+NOyõ95_Ð‘“”’*ÿÿÿÿ+!v!NO¬ƒõ33 Function.prototype.valueOf.apply(stream)5_Ð’“2ÿÿÿÿ+!v!NO¬†õ3> Function.prototype.valueOf.apply(stream, arguments)5_ÐvxwÿÿÿÿNO«Çõ3 e5_Ðlnm %ÿÿÿÿNO«õ1' stream.valueOf = function valueOf() {5çª