VimUnDoBCܐf;EBlEcғcP£_P5_P5_P5_Pfunction delay()5_Pfunction delay(source, time)5_Pfunction delay(source, time) {}5_P }5_ Pfunction delay(source, time) {5_ P5_ Pvar accumulate = require()5_ Pvar accumulate = require("")5_ %P5_  P(var accumulate = require("./accumulate")5_ #P%var convert = require("./accumulate")5_P5_Pvar accumulate = require()5_Pvar accumulate = require("")5_P 5_ P convert()5_P convert(source, function())5_P" convert(source, function(_, ))5_+P', convert(source, function(_, next, result))5_-P' / convert(source, function(_, next, result) {})5_P7   5_P;  function next()5_P<  function next() {}5_PA function next() {5_PA }5_PB   5_PF  accumulate()5_ !PH " accumulate(source, function())5_! #PI % accumulate(source, function() {})5_ "! PL # accumulate(source, function() {5_!#"$PO   5_"$# P[   5_#%$ P]  buffer.push()5_$&% P` ( accumulate(source, function(value) {buffer.push(value)  buffer.push(value)5_%'& Pa ; accumulate(source, function(value) { buffer.push(value)})  })5_&('Pr  5_')( P|  function 5_(*)P function drain()5_)+*P€ function drain() 5_*,+P€ function drain() {}5_+-,P function drain() {5_,.-PŠ 5_-/.Pfunction forward() {5_.0/Pšfunction forward(buffer, ) {5_/10Pœfunction forward(buffer) {5_021P function react(buffer) {5_132 )P¹ > accumulate(source, function(value) { buffer.push(value) })5_243 P»  buffer.push(value) })5_354 P½   5_475 P  react()5_5867 P   5_798 P  function react()5_8:9 P  function react() {}5_9;: P   5_:<; P    5_;=<P  setTimeout()5_<>=P  setTimeout() {}5_=?> P   5_>@?P setTimeout() {5_?A@P setTimeout(function()5_@BAP  setTimeout(function() {}5_ACBP! }5_BDCP" }5_CEDP= 5_DFE PE var defer()5_EGFPI5_FHGPK 5_GIHPR setTimeout()5_HJIPm5_IKJPm buffer.push(value)5_JLKPn react(buffer, next)5_KML Pq  function react() {5_LNM Pr  active = true5_MON Pr  setTimeout(function() {5_NPO Ps  })5_OQP Ps  }5_PRQPy5_QSRP{5_RTSP~* setTimeout(deliver, deferred, value)5_SUT Pà   5_TVU PÅ  ms5_UWV PÅ   5_VXWPØ 5_WYXPÚ 5_XZY PÛ   5_Y[Z Pð  when()5_Z\[ Pó  var buffer = []5_[]\ Pô  var active = true5_\^] Põ   5_]_^ P  when()5_^`_ P  when(head, function())5__a` P  when(head, function() {})5_`ba P  when(head, function() {5_acb P   5_bdc P   5_ced *P - convert(source, function(_, next, result) {5_dfe"P % when(head, function ondeliver() {5_egf P next()5_fhgP next(value, start)5_gih )P , convert(source, function(_, next, start) {5_hji P  var result = start5_ikjP( accumulate(source, function(value) {5_jlk.P#1 accumulate(source, eventual(function(value) {5_kml P0  var head = defer()5_lnm P0 * when(head, function ondeliver(value) {5_mon P1 ! result = next(value, start)5_npo P1  })5_oqpP:5_prqP=var eventual = require()5_qsrP=var eventual = require("")5_rtsPE5_sutPEfunction react(buffer, ) {5_tvuPF}5_uwvPG5_vxwPKvar defer = require()5_wyxPKvar defer = require("")5_xzy"PN5_y{zPSvar deliver = require()5_z|{PTvar deliver = require("")5_{}|%PW'var deliver = require("eventual/delay")5_|~}Pb })5_}~P 5_~Pď return ()5_PĒ return when()5_Pĝ return when(deferred, )5_&PĞ' return when(deferred, function())5_(Pğ* return when(deferred, function() {})5_%Pġ( return when(deferred, function() {5_)PĤ 5_PĨ result5_Pī result = next()5_Pĵ }))5_PĻ result = next(result)5_ P   5_ P  var forward = eventual()5_P 5_ P return forward()5_P result = forward()5_P return forward()5_P- return when(deferred, function(value) {5_P$ result = next(value, result)5_P })5_ P 9 accumulate(source, eventual(function(value, result) {5_P }), result)5_P 5_Pmodule.exports = deliver5_ P= - convert(source, function(_, next, result) {5_PŽ # return forward(value, result)5_%P; 5_PD  console.log()5_%P]& return forward(deferred, result)5_Px  5_P var when = require()5_Pƀ var when = require("")5_ PƄ 5_ PƆ when()5_PƋ console.log(value)5_Pƻ! when(deferred, console.log)5_P 0 accumulate(source, function(value, result) {5_P }, result)5_#P$ return forward(deferred, null)5_ P  9 accumulate(source, eventual(function(value, result) {5_P# }), result)5_P##var when = require("eventual/when")5_ P#$   5_P#'  console.log()5_P#P  console.log(value, result)5_ P#V 0 accumulate(source, function(value, result) {5_P#\" }, result)5_P#  var deferred = defer()5_ v P#. setTimeout(deliver, ms, deferred, value)5_ v P##& return forward(deferred, result)5_& v P#. setTimeout(promise, ms, deferred, value)5_ v P#- setTimeout(promise, ms, promise, value)5_ v P#$+ setTimeout(delay, ms, promise, value)5_  v P$  var forward = eventual(next)5_   v P$ 9 accumulate(source, eventual(function(value, result) {5_  v P$ }), result)5_   v P$  var promise = defer()5_  v P$ % return forward(promise, result)5_   v P$ - setTimeout(deliver, ms, promise, value)5_   v P$ 0 setTimeout(function(), ms, promise, value)5_   v P$ 3 setTimeout(function() {}, ms, promise, value)5_  v P$  }, ms, promise, value)5_   v P$   5_  v P$  result = next()5_ "  v P$   5_ 1 v P$ 4 return convert(source, function(_, next, result) {5_  v P$ }, result)5_ - v P$ 0 accumulate(source, function(value, result) {5_ / v P$% 4 return convert(source, function(_, next, inital) {5_  v P(  var result = initial5_  v P(  var timout = ms5_  v P( }, ms)5_  v P(  var timeout = ms5_  v P(  var timeout = []5_  v P(   5_vP(  timeout = timeout + ms5_vP(  5_vP( }, timeout)5_vP( 5_  vP(   5_  vP(  var rs5_   vP(  var result = initial5_   2vP(& 5 return convert(source, function(_, next, initial) {5_   vP+'  ms = ms || 15_  vP+(  ms = ms || 105_  $vP+ F ms = ms || 10 // Set minimum of 10 to otherwise it's little mixed up5_ 4vP+ H ms = ms || 10 // Set minimum of 10ms to otherwise it's little mixed up5_ &vP+ ; ms = ms || 10 // Set minimum of 10ms it's little mixed up5_ [vP+) [ ms = ms || 10 // Set minimum of 10ms, otherwise tests are unreliable it's little mixed up5_vP-b)var deliver = require("eventual/deliver")5_  vP-b%var defer = require("eventual/defer")5_  vP-c,+var eventual = require("eventual/decorate")5_  vP-F ms = ms || 10 // Set minimum of 10ms, otherwise tests are unreliable5_   vP|   5_   vP|  console.l5_   vP|   5_  vP|.  console.log()5_   vP|   5_   vP|  return 5_   vP|  var timeout = 05_  vP|  console.log(result)5_   vP| 5_!    vP| return 5_ "!  vP| return vl5_!#"   vP|/ $ result = next(value, result)5_"$#   vP| , value = result = next(value, result)5_#%$  vP|0 return value5_$&%   vP|1  var timeout = 0, value5_%'&   vP|   5_&('   vP|  consol5_')(vP| 5_(*)vP}2 console.log()5_)+* vP}-   5_*,+ vP}.  if ()5_+-,'vP}95_,.-'vP}<(var accumulate = require("./accumulate")5_-2.''vP}?6)var accumulated = require("./accumulate")5_.312 'vP}i 0 if (result && result.is === accumulated)5_243 !'vP}l 1 if (!result && result.is === accumulated)5_354 1'vP}n 1 if (!result && result.is !== accumulated)5_465 4'vP}p 4 if (!result && result.is !== accumulated) {}5_576'vP}q  timeout = timeout - ms5_687'vP}r$ result = next(value, result)5_798 'vP}s 5_8:9'vP}t 5_9;: 'vP}- result && result.is === accumulated5_:<;1'vP} nexn1 if (result && result.is === accumulated5_;=<'vP} nexn()5_<>='vP} next()5_=?>'vP} next(end())5_>@?#'vP}5_?A@'vP}var end = require()5_@BA'vP}7var end = require("")5_ACB'vP}8 3 if (!result && result.is !== accumulated) {5_BDC'vP}9 console.log(result)5_CED 'vP}; E ms = ms || 1 // Set minimum of 10ms, otherwise tests are unreliable5_DFE #'vP~ = E ms = ms || 3 // Set minimum of 10ms, otherwise tests are unreliable5_EGF /'vP~ D ms = ms || 3 // Set minimum of 3ms, otherwise tests are unreliable5_FHG )'vP~  ? ms = ms || 3 // Set minimum of 3ms, as 0 tests are unreliable5_GIH 3'vP~# B ms = ms || 3 // Set minimum of 3ms, as on 0 tests are unreliable5_HJI ?'vP~) N ms = ms || 3 // Set minimum of 3ms, as on 0 order of dispatch are unreliable5_IKJ G'vP~+> Q ms = ms || 3 // Set minimum of 3ms, as on 0 order of dispatch is are unreliable5_JLK 'vP~4 M ms = ms || 3 // Set minimum of 3ms, as on 0 order of dispatch is unreliable5_KML ,'vP~< F ms = ms || 3 // Minimum 3ms, as on 0 order of dispatch is unreliable5_LNM ,'vP~A C ms = ms || 3 // Minimum 3ms, as on less of dispatch is unreliable5_MON 5'vP~B @ ms = ms || 3 // Minimum 3ms, as on less dispatch is unreliable5_NPO 8'vP~D C ms = ms || 3 // Minimum 3ms, as on less dispatch order unreliable5_OQP ;'vP~E@ F ms = ms || 3 // Minimum 3ms, as on less dispatch order is unreliable5_PRQ 'vP~f  var timeout = 05_QSR0'vP~n 3 if (!result || result.is !== accumulated) {5_RTS2'vP~x2 if (result && result.is === accumulated)5_SUT5'vP~y5 if (result && result.is === accumulated) {}5_TVU$'vP~z 5_UWV 'vP~|A 5_VXW 'vP~B " var timeout = 0, ended = false5_WYXPCvar end = require("./end")5_XZYPD% next(end(), result.value)5_Y[ZP$*var accumulated = require("./accumulated")5_Z\[&P*E(var isReduced = require("./accumulated")5_[]\1P24 if (result && result.is === accumulated) {5_\^]P7F if (isReduced()) {5_]_^ P.G 4 return convert(source, function(_, next, result) {5_^`_PXIfunction delay5__a`PXMfunction delay()5_`baPXOfunction delay(source, ms)5_acbPXOfunction delay(source, ms) {}5_bdcPXP  5_ced PXV !  5_dfePX\ ! return reducible()5_egfPX] ! return reducible(function())5_fhgPX^!!! return reducible(function() {})5_gihPXa " return reducible(function() {5_hji(PXh!# !"5_ikj PXq!# reduce()5_jlk PXu!# reduce(source, function())5_kml PXu"#! reduce(source, function() {})5_lnm PX!$ reduce(source, function() {5_mon (PX "%  "$5_npo!PX "% setTimeout()5_oqp!PX "% setTimeout(function())5_prq!PX #% setTimeout(function() {})5_qsrPX!' !&5_rts PX!' function accumulate()5_sut PX"' function accumulate() {}5_tvu PX!( function accumulate() {5_uwv $PX ")  "(5_vxwPX!* !)5_wyx'PX&(* })5_xzy"PX!#* 5_y{z$PX$&+ $&*5_z|{%PX%', %'+5_{}|&PY%', setTimeout()5_|~}&PYT%',- setTimeout(deliver, ms, promise, value)5_}~&PYV%',0 setTimeout(function(), ms, promise, value)5_~&PYW%(,3 setTimeout(function() {}, ms, promise, value)5_&PY[&(. &(-5_ PY|  var accumulated = initial5_ PY} ( function accumulate(result, value) {5_ PY}  accumulated5_ PY~  }5_PY~!+ !*5_$PY#%+ 5_$PY#%+ deliver()5_$PY#%+ deliver(promise, )5_ PY  var promise = defer()5_!PY ! var promise = defer()5_$PY#$ setTimeout(function() {5_$PY#$ })5_ PY "(  "'5_!PY "( var promise = 5_$PY$&) $&(5_PY!* !)5_$PY#%* deliver(promise, value)5_$PZ#%*$ deliver(promise, next(value)5_$,PZ#%*, deliver(promise, next(result, value)5_%PZ$&* }, ms, promise, value)5_ PZ "+  "*5_!PZ "+ function forward()5_!PZ> "+% function forward(last, promise, )5_!PZC "+" function forward(a, promise, )5_!PZE "+ function forward(promise, )5_!3PZO "+3 function forward(promise, after, result, value)5_!5PZO #+6 function forward(promise, after, result, value) {}5_!PZk!#- !#,5_"PZm!#- deliver()5_"PZs!#- deliver(promise, )5_"PZt!#- deliver(promise, ())5_"PZv!#- deliver(promise, next())5_"*PZ{"$-5_!PZ!#/ !#.5_" PZ!#/ when()5_"PZ!#/ when(after)5_"PZ!#/ when(after, 5_!PZ !5 function forward(promise, after, result, value) {5_!PZ ! return when(after, 5_!PZ !+ deliver(promise, next(result, value))5_!PZ !5_!PZ ! }5_"PZ!" var promise = defer()5_"PZ!" setTimeout(function() {5_"PZ!"- deliver(promise, next(result, value))5_"PZ!" })5_"PZ!" return promise5_ PZ!% var last = defer()5_!PZ!#& !#%5_" PZ!#& when()5_"PZ!#& when(previous, function())5_"!PZ!$&# when(previous, function() {})5_"PZ!#'! when(previous, function() {5_"$PZ"$( "$'5_# PZ"$( next()5_#PZ"$( next(result)5_#PZ"$( next(result, value)5_"PZ"$(5_#PZ"#5_ P[!( var previous = defer()5_"P[!#(( return when(previous, function() {5_" P[*!#(' return when(promise, function() {5_!"P[1 "(, reduce(source, function(result, value) {5_"P[4!#(, var state = when(promise, function() {5_#P[6"$(" return next(result, value)5_$P[O$&) $&(5_%P[U$&) var promise = defer5_ P[n!) var promise = defer()5_!!P[z ")+ reduce(source, function(state, value) {5_&P[~%') }, initial)5_"P[!#)- var result = when(promise, function() {5_%P[$% promise = defer()5_" P["$) "$(5_#P["# setTimeout5_!P[!#) !#(5_!#P[ ")- reduce(source, function(promise, value) {5_#P["$)' return when(promise, function() {5_%P[%'* %')5_#P[#%+ #%*5_$P[#%+ setTimeout()5_$P[#%+* setTimeout(delivered, promise, ms)5_$-P[#%+. setTimeout(delivered, ms, promise, ms)5_%P\ $&+! return next(state, value)5_# P\"$+( return when(previous, function() {5_%P\$&+ next(state, value)5_%P\&$&+# result = next(state, value)5_JvJP\4+ ms = ms || 35_vP\:+function delay(source, ms) {K ms = ms || 3 // Minimum 3ms, as on less dispatch order becomes unreliable2 return convert(null, function(_, next, result) { var timeout = 0 var ended = false( accumulate(source, function(value) { setTimeout(function() { if (!ended) { timeout = timeout - ms& result = next(value, result)" if (isReduced(result)) { ended = true$ next(null, result.value) } } }, timeout = timeout + ms) return result }) })}5_vP\;5_vP\;5_vP\<5_vP\L(var accumulate = require("./accumulate")5_"vP\O$var reduce = require("./accumulate")5_ vP\R"var convert = require("./convert")5_"vP\U$var reducible = require("./convert")5_ vP\b  var promise = define()5_ vP\c ! when(previous, function() {5_vP\f return promise5_vP\hvar when = require5_ vP\lvar when = require()5_ vP\lHvar when = require("")5_  vP\r  5_ vP\z var 5_ vP\ var defer = require()5_ vP\ var defer = require("")5_" vP\  5_  vP\ var deliver = require()5_  vP\I var deliver = require("")5_ vP\J* setTimeout(delivered, ms, promise)5_ vP\ 5_ vP\5_ vP\( setTimeout(deliver, ms, promise)5_ vP\5_ vP\ var promise = defer()5_ vP\ 5_  vP\ if ()5_ vP\ if (isReduced())5_ vP\ if (isReduced(result))5_ vP\  var result = initial5_ vP\5_ vP\  var result = defer()5_ vP\ . reduce(source, function(previous, value) {5_ vP\5_+ vP\ 5 return reduce(source, function(previous, value) {5_ vP] })5_" vP] 5_  vP]   5_ vP]  var promise = defer()5_ vP]5_  vP] when()5_ vP]" when(promise, function())5_  vP]#" when(promise, function() {})5_ vP]6 5_ vP]; 5_ vP]A setTimeout()5_  vP]E setTimeout(deliver)5_   vP]F5_    vP]O  var promise = null5_    vP]U5_    vP]Y when(promise, function() {5_   vP]a 5_  vP]j setTimeout()5_& vP]v 5_ vP]~ result = next()5_" vP] 5_  vP] if ()5_ vP] if (isReduced())5_ vP] if (isReduced(result))5_'vP]( setTimeout(deliver, ms, promise)5_'vP] 5_'vP]5_'vP]5_ 'vP], if (isReduced(result)) return result5_ 'vP]- if (!isReduced(result)) return result5_'vP] 5_ 'vP]! if (!isReduced(result)) { setTimeout(deliver, ms, promise)* setTimeout(deliver, ms, promise)5_'vP] 5_'vP] else deliver()5_ $'vP^& else deliver(promise, Error())5_! %'vP^( else deliver(promise, Error(""))5_ "!'vP^( return when(previous, function() {5_!#"'vP^$ result = next(result, value)5_"$#'vP^  if (isReduced(result)) 5_#%$'vP^ K })5_$&%'vP^  var promise = defer()5_%'&'vP^  var previous = defer()5_&(''vP^5_')('vP^5_(*)'vP^ 5_)+*'vP^ 5_*,+ 'vP^ when()5_+-,'vP^ when(previous, function())5_,.-!'vP^# when(previous, function() {})5_-/.'vP^ 5_.0/'vP^ setTimeout()5_/10 'vP^5_021@vP^5_132 @vP^!@ if (!isReduced(result)) setTimeout(deliver, ms, promise)5_243 @vP^"* setTimeout(deliver, ms, promise)5_354@vP_" if (!isReduced(result))5_465(@vP_") if (!isReduced(result)) deliver()5_576 (@vP_  var reduced = Error # "5_687 @vP_ $var reduced = Error()5_798 @vP_ $var reduced = Error("")5_8:91@vP_$2 if (!isReduced(result)) deliver(promise, )5_9;:/@vP_$9 if (!isReduced(result)) deliver(promise, reduced)5_:<; @vP_$$9 if (!isReduced(result)) deliver(current, reduced)5_;=<@vP_%$( setTimeout(deliver, ms, promise)5_<>=,@vP_)$- else setTimeout(deliver, ms, promise)5_=?>@vP_1$5_>@?@vP_7( setTimeout(deliver, ms, current)5_?A@@vP_<' return when(promise, function() {5_@BA@vP_=$ result = next(result, value)5_ACB@vP_=@ if (!isReduced(result)) setTimeout(deliver, ms, promise)5_BDC@vP_=/ else deliver(promise, Error("reduced"))5_CED@vP_> return result5_DFE@vP_> })5_EGF@vP_A! when(previous, function() {5_FHG@vP_EL promise = defer()5_GIH@vP`n var previous = null5_HJI@vP`s 5_IKJ@vP`zM setTimeout()5_JLK@vP`N var previous = defer5_KML@vP`% setTimeout(deliver, previous, ms)5_LNM(@vP`O) setTimeout(deliver, ms, previous, ms)5_MSN@vPa  5_NTOS@vPa  var result = defer()5_SUT@vPa!  5_TVU@vPa ret5_UWV@vPa !  5_VXW@vPa var previous = defer()5_WYX@vPa!  5_XZY@vPa!3 return reduce(source, function(result, value) {5_Y[Z@vPa" !5_Z\["@vPa", reduce(source, function(result, value) {5_[]\@vPa var previous = defer()5_\^]@vPa var current = defer()5_]_^@vPa / var promise = when(previous, function() {5_^`_8@vPa 8 if (isReduced(result)) deliver(current, reduced)5__a`@vPb & if (isReduced(result)) reduced5_`ba%@vPb!  5_acb-@vPb!- if (isReduced(result)) return reduced5_bdc @vPb!! if (isReduced(result)) {}5_ced@vPb# "5_dfe@vPb# deliver()5_egf&@vPb#$ #5_fhg @vPb/$ }5_gih@vPb1$ } else {}5_hji@vPb2& %5_ikj@vPbF' &5_jlk  @vPbK' setTimeout()5_kml&  @vPbR( '5_lnm!!@vPbW var 5_mon  @vPbX- else setTimeout(deliver, ms, current)5_npo@vPbX return result5_oqp@vPbZ previous = current5_prq@vPbZ return promise5_qsr@vPbe# }, initial)5_rts@vPbhP% setTimeout(deliver, ms, previous)5_sut  !vPb!" return promise}5_tvu   vPb!! 5_uwv  vPb!"  !5_vxw ""vPbQ }5_wyx!!vPb# "5_xzyvPb# var start = defer()5_y{zvPb$ #5_z|{vPb 5_{}|)vPb#, return reducible(function(next, initial) {5_|~}vPb var result = initial5_}~vPb# "5_~vPb var sta5_vPb# "5_vPb# setTimeout()5_vPb # }, defer())5_$vPb#. reduce(source, function(previous, value) {5_vPb#! when(previous, function() {5_!vPb#+ reduce(source, function(timer, value) {5_"vPb#( return when(previous, function() {5_"vPb# var timer = defer()5_'"vPb#( setTimeout(deliver, ms, timer)5_"vPbR# return timer5_"vPc var promise = defer()5_"vPc"- reduce(source, function(timeout, value) {5_ "vPc"4 return reduce(source, function(timeout, value) {5_"vPd  " return promise5_"vPd  " return when()5_$"vPd "% return when(complete, function())5_&"vPd!"( return when(complete, function() {})5_"vPd!$ !#5_ "vPd! $& return when(complete, function() { return result!$ return result5_ "vPd#S #4 return when(complete, function() { return result})!# })5_)"vPd6"* setTimeout(deliver, ms, timeout)5_'"vPd:"( deliver(promise, result.value)5_ "vPd<* deliver(promise, result.value, )5_"vPdE" !5_"vPdg return result5_"vPdp!" setTimeout(deliver, ms, start)5_"vPdt!. var timer = setTimeout(deliver, ms, start)5_4v4Pdy!5 var timer = defer()setTimeout(deliver, ms, start)5_4v4Pdz var start = defer()5_ 4v4Pd|  }, start)5_ 4v4Pd!  5_!4v4Pd!" setTimeout(deliver, ms, start)5_!4v4Pd!" setTimeout(deliver, ms, timer)5_ "vPd! }, timer)5_ "vPd! var timer = defer()5_1"vPd!2 setTimeout(deliver, ms, timeout, result)5_"vPdT" !5_!"vPeSd!#"5_ "vPe result = result.value5_ "vP# "5_"vP# deliver()5_"vPE#% deliver(timeout, reduced, )5_"vPK#& deliver(complete, reduced, )5_$"vPO_#% deliver(timeout, reduced, )5_""vP## deliver(timeout, reduced)5_ "vPf return reduced5_!"vPg"" deliver(timeout, result)5_"vPh" deliver(timeout)5_"vP# "5_'"vPi#( deliver(timeout, result.value)5_"vP'n# deliver(timeout)5_#"vPPo## deliver(timeout, reduced)5_6"vP^ #7 return when(complete, function() { return result })5_B"vP_ #C return when(complete, function() { return result }, function())5_D"vP`!#F return when(complete, function() { return result }, function() {})5_"vPa!% !$5_ "vPc!% if ()5_A"vP %D return when(complete, function() { return result }, function() {5_ *"vPp!%* return error === reduced ? result : 5_"vP% "use strict";&var reducible = require("./reducible") var reduce = require("./reduce")'var isReduced = require("./is-reduced")#var when = require("eventual/when")%var defer = require("eventual/defer"))var deliver = require("eventual/deliver")var reduced = Error("reduced")function delay(source, ms) {K ms = ms || 3 // Minimum 3ms, as on less dispatch order becomes unreliable+ return reducible(function(next, result) { var timeout = defer()< var complete = reduce(source, function(timeout, value) {' return when(timeout, function() {$ result = next(result, value) if (isReduced(result)) { result = result.value return reduced } else { timeout = defer()* setTimeout(deliver, ms, timeout) return timeout } }) }, timeout)$ setTimeout(deliver, ms, timeout)I return when(complete, function() { return result }, function(error) {/ return error === reduced ? result : error }) })}module.exports = delay5_ "vP>"var convert = require("./convert")5_""vPA$var reducible = require("./convert")5_ "vPH 2 return convert(null, function(_, next, result) {5_ "vPL 4 return reducible(null, function(_, next, result) {5_ "vPOq . return reducible(function(_, next, result) {5_"vP5_"vPvar end = require()5_"vPrvar end = require("")5_"vPv$ next(null, result.value)5_""vPw# next(end, result.value)5_ "vPx K ms = ms || 3 // Minimum 3ms, as on less dispatch order becomes unreliable5_ "vPy K ms = ms || 5 // Minimum 3ms, as on less dispatch order becomes unreliable5_ "vPz L ms = ms || 30 // Minimum 3ms, as on less dispatch order becomes unreliable5_ "vP{ L ms = ms || 10 // Minimum 3ms, as on less dispatch order becomes unreliable5_ "vP| K ms = ms || 8 // Minimum 3ms, as on less dispatch order becomes unreliable5_ "vP! K ms = ms || 7 // Minimum 3ms, as on less dispatch order becomes unreliable5_ "vP#} K ms = ms || 7 // Minimum 3ms, as on less dispatch order becomes unreliable5_ "vP+~ K ms = ms || 6 // Minimum 3ms, as on less dispatch order becomes unreliable5_ "vP2 K ms = ms || 5 // Minimum 3ms, as on less dispatch order becomes unreliable5_ "vP5 K ms = ms || 6 // Minimum 3ms, as on less dispatch order becomes unreliable5_PB(var accumulate = require("./accumulate")5_"PB$var reduce = require("./accumulate")5_ PB ( accumulate(source, function(value) {5_ PB ' reducible(source, function(value) {5_PB&var reducible = require("./reducible")5_PB var reduce = require("./reduce")5_PB'var isReduced = require("./is-reduced")5_PBvar end = require("./end")5_ PB + return reducible(function(next, result) {5_ PC $ reduce(source, function(value) {5_PC   setTimeout(function() {5_P’5_P—var setTimeout = require()5_P˜var setTimeout = require("")5_"P›"var setTimeout = require("timers")5_#Pœ#var setTimeout = require("timers");5_.PŸ.var setTimeout = require("timers").setTimeout;5_,vP¡-var setTimeout = require("timers").setTimeout5_,vP¡5_,vP¢5_"vPt5_ "vP    var result = sta5_!"vPQY#" deliver(timeout, result)5_6"vPlZ #7 return when(complete, function() { return result })5_!"vPs[#( deliver(timeout, result.value)5_'"vPb# deliver(timeout)5_"vPc## deliver(timeout, reduced)5_""vP#& deliver(timeout, complete, )5_%"vPW#2 deliver(timeout, complete, result.value)5_NPSO@vPa5_OQP @vPa, reduce(source, function(result, value) {5_PRQ"@vPa+ reduce(source, function(steat, value) {5_QR!@vPa+ reduce(source, function(state, value) {5_./21 'vP}f 5_.01/ 0'vP}C4 7 if (result && result.is === accumulated) return5_/0 7'vP}X5 > if (result && result.is === accumulated) return result5_   vP-5_   v P$ * setTimeout(next, ms, promise, value)5_%P#!$ return forward(deferred, null)5_ P#i 5_P#j var when = require()5_P#n var when = require("")5_P#n var when = require("eventual")5_P#o #var when = require("eventual/when")5_!P#w  when()5_ P#{ when(deferred, )5_P % return forward(promise, result)5_ P     var previous = deferred5_P   var previous = null5_P!  when()5_ P! when(previous, function())5_P!# when(previous, function() {})5_!P!! when(previous, function() { })5_P!5_P!5_P"  5_ P"     var deferred = defer()5_P"  setTimeout()5_P"# setTimeout(deliver, deferred, )5_P"%  var promise = defer()5_ P"*" setTimeout(deliver, promise, )5_!P"1$ setTimeout(deliver, promise, ms)5_P"b5_P"g 5_P"h var promise = defer()5_&P"k- setTimeout(deliver, ms, promise, value)5_P"o/ setTimeout(deliver, ms, promise, value)5_ P"    var result = null5_P"  var result5_P"  var previous5_P"5_P"5_P"  when()5_ P" when(previous)5_P" when(previous, 5_P"'setTimeout(deliver, ms, promise, value)D when(previous, functionsetTimeout(deliver, ms, promise, value)! when(previous, function() {5_P"  })5_P", previous = when(previous, function() {5_ P   var setTimeout =5_ P   onTimeout =5_ P  onTimeout = eventual()5_ P   onTimeout = eventual(setTimeout)5_ P  5_ P  $var onTimeout = eventual(setTimeout)5_-P 8 setTimeout(deliver, ms, deferred, value, previous)5_6P   previous = deferred5_P!A  setTimeout5_P!J5_ P!V7 onTimeout(deliver, ms, deferred, value, previous)5_ P! 5_ P! 5_7P! . setTimeout(deliver, ms, deferred, value)5_ P     var deferred5_%P! $ return forward(deferred, null)5_PŹ0 //setTimeout(deliver, ms, deferred, value)5_576 P  buffer.5