VimUnDo' :*exports['test hub with error stop'] = function(assert, done) {5_2NO{13v6 var source = hub(pipe(readers)), stream = readers[0]5_FNOEGv6 var source = hub(pipe(readers)), stream = readers[0]5_ DNOCEv8exports['test hub with interrupt'] = function (assert) {5_ pNOop5_ NOuAexports['test stakc with normal stop'] = function(assert, done) {5_ !!!vNO? "u copies.push(copy(source))5_ !!!vNO@ ! 5_  !!vNOA!u!t5_ ,,7v7NOJu8 var source = stack(pipe(readers)), stream = readers[0]5_,,7v7NOKu, var source = stack(pipe(readers)), stream 5_ ,7v7NOO "v  "u5_!,7v7NOP  "v = readers[0]5_,$,7v7NOc+-v9 test(assert, Object, copies[0], [ 'a', 'b', 2, 'last'])5_,%,7v7NOe +-v; test(assert, Object, copies[0], [ 1 'a', 'b', 2, 'last'])5_-$-$-,v,NO,.v0 test(assert, Object, copies[1], [ 2, 'last' ])5_-$-$-,v,NO ,.v' test(assert, Object, copies[1], [ ])5_3%-$-,v,NO25v8 var source = stack(pipe(readers)), stream = readers[0]5_3-$-,v,NO24w# var source = stack(pipe(readers))5_4-$-,v,NO35w var stream = readers[0]5_777vNO68w copies.push(copy(source))5_777vNO67 5_377vNO35w 35v5_388vNO35w5_B$99vNOACx@ test(assert, Object, copies[0], [ 'a', 'b', 2, 'last'], error)5_C$C$C,v,NOBDx7 test(assert, Object, copies[1], [ 2, 'last' ], error)5_ C%C$C,v,NOBDx. test(assert, Object, copies[1], [ ], error)5_! C$C$C,v,NO BDx- test(assert, Object, copies[1], [ ], error)5_ "!IC$C,v,NO HJx8 var source = stack(pipe(readers)), stream = readers[0]5_!#"C$C,v,NOx+ var source = stack(pipe(readers)), stream5_"$#3C$C,v,NOx3 var stream, source = stack(pipe(readers)), stream5_#%$I-C$C,v,NOHLx@ var stream, source = stack(pipe(readers)), stream = readers[0]5_$&%QQTvNOPRz source(function (element) { buffers[0].push(element)- if (buffers[0].length === 3) return false }, stops.push.bind(stops))5_%'&JQQvNOJOx JLw5_&('TTTvNOSU{ buffers[0] = []5_')(TTTvNOST 5_(*)TTTvNOST 5_)+*TTTvNOST5_*,+JTTvNOJLy JLx5_+-,TUUvNO ST5_,.-TTTvNO TVx5_-/.XX\vNOWYy buffers[1] = [] source(function (element) { buffers[1].push(element)- if (buffers[1].length === 4) return false }, stops.push.bind(stops))5_.0/XXXvNOWX 5_/10PXXvNOPVu PRt5_021P]]vNOPRy5_132aafvNO#`bz buffers[2] = [] source(function (element) { buffers[2].push(element)- if (buffers[2].length === 4) return false }, stops.push.bind(stops))5_243aaavNO#`a 5_354WaavNO%W_tWYs5_465XhhvNO(WYzbuffers[2] = []5_576bhhvNO+ab5_687XX]vNO0WYy buffers[2] = [] source(function (element) { buffers[2].push(element)- if (buffers[2].length === 4) return false }, stops.push.bind(stops))5_798XXXvNO1WX 5_8:9\XXvNO3[\5_9;:\XXvNO4[\5_:<;]XXvNO5\]5_;=<]XXvNO5\]5_<>=^XXvNO;^fo ^`n5_=?>^XXvNO>^`u5_>@?j!XXvNOFikv1 assert.deepEqual(buffers[0], [ 'c', 'd', 'e' ],5_?A@j$XXvNOJikv3 assert.deepEqual(buffers[0], [ 'a'c', 'd', 'e' ],5_@BAj&XXvNOLikv6 assert.deepEqual(buffers[0], [ 'a', 'c', 'd', 'e' ],5_ACBj)XXvNONikv8 assert.deepEqual(buffers[0], [ 'a', 'b'c', 'd', 'e' ],5_BDCj+XXvNOOikv: assert.deepEqual(buffers[0], [ 'a', 'b', c', 'd', 'e' ],5_CEDj0j0j7v7NORikv; assert.deepEqual(buffers[0], [ 'a', 'b', 'c', 'd', 'e' ],5_DFEj0j0j7v7NOSikv3 assert.deepEqual(buffers[0], [ 'a', 'b', 'c', ],5_EGFl!j0j7v7NOXkmv6 assert.deepEqual(buffers[1], [ 'e', 'f', 'g', 'h' ],5_FHGl8j0j7v7NO_kmv; assert.deepEqual(buffers[1], [ 'd', 'e', 'f', 'g', 'h' ],5_GIHn+j0j7v7NOqmov1 assert.deepEqual(buffers[2], [ 'f', 'g', 'h' ],5_HJIn!j0j7v7NOtmov& assert.deepEqual(buffers[2], [ h' ],5_IKJqj0j7v7NR_yrtexportsqtwqsv5_JLKsj0j7v7NR_}rtx exports''5_KMLsj0j7v7NR_rtx exports[]5_LNMs j0j7v7NR_rtx exports['']5_MONsj0j7v7NR_rtxexports['test ']5_NPOs'j0j7v7NR_rtx'exports['test pull form stack on read']5_OQPs3j0j7v7NR_rtx4exports['test pull form stack on read'] = function()5_PRQs:j0j7v7NR_rtx:exports['test pull form stack on read'] = function(assert)5_QSRs<j0j7v7NR_rux=exports['test pull form stack on read'] = function(assert) {}5_RTSsj0j7v7NR_suy5_SUTtj0j7v7NR_suz5_TVU j0j7v7NR_ z+var stack = require('../streamer.js').stack5_UWV (j0j7v7NR_ z.var streamer = require('../streamer.js').stack5_VXW k0k7v7NR_ { stack = streamer.stack5_WYX k0k7v7NR_ { stack = streamer.stack, 5_XZY #k0k7v7NR_ {/ stack = streamer.stack, list =streamer.list5_Y[Z "k0k7v7NR_ {0 stack = streamer.stack, list =s treamer.list5_Z\[ %k0k7v7NR_ {1 stack = streamer.stack, list = s treamer.list5_[]\uk0k7v7NR_tv{ var stack = 5_\^]uk0k7v7NR_tv{ var stack = streamer.list()5_]_^u k0k7v7NR_tv{ var stack = 5_^`_uk0k7v7NR_tv{ var source = 5__a`uk0k7v7NR_tv{ var source = stack()5_`bauk0k7v7NR_tv{ var source = stack(list())5_acbu k0k7v7NR_vx sourceux| uw{5_bdcvk0k7v7NR_vx~vx}5_cedwk0k7v7NR_vx~ function 5_dfew k0k7v7NR_vx~ function 5_egfwk0k7v7NR_vx~ function dequeue()5_fhgwk0k7v7NR_vy~ function dequeue() {}5_gihwk0k7v7NR_wy wy5_hjix k0k7v7NR`wy source()5_ikjxk0k7v7NR`wx source(function())5_jlkwk0k7v7NR`wy wy5_kmlwk0k7v7NR` vx function dequeue() {5_lnmu#k0k7v7NR` tv# var source = stack(list(1, 2, 3))5_monu.k0k7v7NR`tv. var source = stack(list(1, 2, 3)), buffer = 5_npox k0k7v7NR`wy element5_oqpxk0k7v7NR`wy buffer.push()5_prqxk0k7v7NR`xz xz5_qsryk0k7v7NR` y{ y{5_rtszk0k7v7NR`&yz sou5_sutxk0k7v7NR`&xz xz5_tvuy k0k7v7NR`*xz source()5_uwvwk0k7v7NR`.vx function dequeue(element) {5_vxwyk0k7v7NR`2xz source(dequeue, )5_wyxyk0k7v7NR`5xz source(next, )5_xzy|k0k7v7NR`9{| source()5_y{zvk0k7v7NR`Avxvx5_z|{wk0k7v7NR`Cvx function5_{}|w k0k7v7NR`Dvx function5_|~}wk0k7v7NR`Fvx function stop()5_}~wk0k7v7NR`Gvy function stop() {}5_~wk0k7v7NR`Hwy5_xk0k7v7NR`Wwy5_xk0k7v7NR`\wy asi.deepEqual()5_xk0k7v7NR`^wy asi.deepEqual(buffer, [])5_x%k0k7v7NR`bwy& asi.deepEqual(buffer, [ 1, 2, 3 ])5_x(k0k7v7NR`cwy* asi.deepEqual(buffer, [ 1, 2, 3 ], '')5_x;k0k7v7NR`pwy; asi.deepEqual(buffer, [ 1, 2, 3 ], 'all elements read')5_xk0k7v7NR`swy< asi.deepEqual(buffer, [ 1, 2, 3 ], 'all elements read');5_x?k0k7v7NR`uwy? assert.deepEqual(buffer, [ 1, 2, 3 ], 'all elements read');5_~k0k7v7NR`~ ~5_ k0k7v7NR`~ source()5_u0k0k7v7NR`tv0 var source = stack(list(1, 2, 3)), buffer = []5_zk0k7v7NR`y{ function next(element) {z| z|5_u<k0k7v7NR`tv< var source = stack(list(1, 2, 3)), buffer = [], called = 35_wk0k7v7NR`wy wy5_y k0k7v7NR`y{ y{5_zk0k7v7NR`y{ console.log()5_vk0k7v7NRcvxvx5_wk0k7v7NRcvx function Stop()5_wk0k7v7NRcvy function Stop() {}5_wk0k7v7NRcwy wy5_wk0k7v7NRcvx function Stop() {5_xk0k7v7NRcwy assert.deepEqual()5_wk0k7v7NRcwy wy5_xk0k7v7NRcwy return function stop()5_xk0k7v7NRcwy return function stop() {}5_yk0k7v7NRcxz assert.deepEqual(expected)5_yk0k7v7NRcy{ y{5_yk0k7v7NRcxz assert.deepEqual(expected)5_yk0k7v7NRcxz( assert.deepEqual(action, expected)5_xk0k7v7NRcwy return function stop() {5_y'k0k7v7NRcxz( assert.deepEqual(actual, expected)5_y*k0k7v7NRcxz, assert.deepEqual(actual, expected, '')5_{k0k7v7NRc{} {}5_|k0k7v7NRc{} function Next()5_|k0k7v7NRc{} function Next(expected)5_|k0k7v7NRc{~ function Next(expected) {}5_|k0k7v7NRc|~ |~5_}k0k7v7NRc|~ return function()5_}k0k7v7NRc|~ return function(elements)5_}k0k7v7NRc|~ return function(element)5_}k0k7v7NRc| return function(element) {}5_u<k0k7v7NRdtv< var source = stack(list(1, 2, 3)), buffer = [], called = 05_u<k0k7v7NRdtv< var source = stack(list(1, 2, 3)), buffer = [], stops = []5_x!k0k7v7NRd xz xz5_yk0k7v7NRdxz stops.push()5_zk0k7v7NRdyz? assert.deepEqual(actual, expected, 'stopped as expected')5_|k0k7v7NRd|~5_}k0k7v7NRd|}5_}k0k7v7NRd}5_~k0k7v7NRd}5_~k0k7v7NRd$} nexts.push()5_~k0k7v7NRd&} nexts.push(elements)5_~k0k7v7NRd'~ ~5_ k0k7v7NRd1~ source()5_k0k7v7NRd4~ source(Stop())5_k0k7v7NRd>~ source(Stop(), Next())5_'k0k7v7NRdE~+ source(Stop(), Next(nexts.length ++))5_(k0k7v7NRdT~* source(Stop(), Next(nexts.length++))5_%k0k7v7NRdY~' source(Stop(), Next(nexts.lengt))5_k0k7v7NRde function stop() {5_k0k7v7NRde called ++5_k0k7v7NRdf> assert.deepEqual(buffer, [ 1, 2, 3 ], 'all elements read')5_k0k7v7NRdf console.log(called)5_k0k7v7NRdf }5_k0k7v7NRdg function next(element) {5_k0k7v7NRdg buffer.push(element)5_k0k7v7NRdg source(next, stop)5_k0k7v7NRdh return false5_k0k7v7NRdh }5_k0k7v7NRdi5_ k0k7v7NRdk source(next, stop)5_k0k7v7NRdn source(Next(), stop)5_!k0k7v7NRds" source(Next(nexts.length), stop)5_k0k7v7NRdz~( source(Stop(), Next(nexts.length))5_k0k7v7NRd|~ source(Next(nexts.length))5_#k0k7v7NRd 5_k0k7v7NRd assert.deepEqual()5_k0k7v7NRd assert.deepEqual(nexts, [])5_%k0k7v7NRd& assert.deepEqual(nexts, [ 1, 2, 3 ])5_(k0k7v7NRd* assert.deepEqual(nexts, [ 1, 2, 3 ], '')5_@k0k7v7NRd 5_k0k7v7NRd5_k0k7v7NRd asi5_k0k7v7NRd assert.deepEqual()5_k0k7v7NRd assert.deepEqual(stops, [])5_=k0k7v7NRd> assert.deepEqual(stops, [ undefined, undefined, undefined ])5_@k0k7v7NRd B assert.deepEqual(stops, [ undefined, undefined, undefined ], '')5_ k0k7v7NRd! 5_ &k0k7v7NRez   5_ l0l7v7NRe~"  head = stream5_uk0k7v7NRevx function shiftux uw5_wk0k7v7NRevx function shift()5_wk0k7v7NRevy function shift() {}5_xk0k7v7NRewy }5_wk0k7v7NRevx function shift() {5_wk0k7v7NRewy wy5_x k0k7v7NRewy source()5_xk0k7v7NRewy source(function onElement())5_x!k0k7v7NRewz# source(function onElement() {})5_xk0k7v7NRewy! source(function onElement() {5_x$k0k7v7NRexz xz5_yk0k7v7NRexz buffer.push()5_yk0k7v7NRey{ y{5_{k0k7v7NRez| })5_{k0k7v7NRez| }, function onStop())5_{k0k7v7NRez} }, function onStop() {})5_{k0k7v7NRez| }, function onStop() {5_{k0k7v7NRe{} {}5_|k0k7v7NRe{} stops.push()5_yk0k7v7NRey{ y{5_z k0k7v7NRey{ shift()5_vNRe  function Stop(expected) {" return function stop(actual) { stops.push(actual) } } function Next(expected) { return function(element) { nexts.push(element)( source(Next(nexts.length), Stop()) return false } }5_uHvNRe#tvH var source = stack(list(1, 2, 3)), buffer = [], stops = [], nexts = []5_vNReC assert.deepEqual(nexts, [ 1, 2, 3 ], 'all elements were yielded')5_vNRe$ source(Next(nexts.length), Stop())5_vNRe5_vNRf5_vNRf. shift()5_  vNRf ( test = utils.test, pipe = utils.pipe   5_  'vNRf   5_   0vNRf/ 0 stack = streamer.stack, list = streamer.list5_   vNRf0 1 stack = streamer.stack, list = streamer.list,head = streamer.head  head = streamer.head5_   wvNRfwy5_  vvNRfvxvx5_ wvNRfvx head()5_wvNRfvx head(source)5_wvNRfvx head(source)()5_wvNRfvx head(source)(function)5_wvNRfvx head(source)(function)5_wvNRfvx head(source)(function())5_w!vNRfvx! head(source)(function(element))5_w vNRfvx" head(source)(function(element)) 5_w"vNRfvy% head(source)(function(element) {}) 5_xvNRfwy }) 5_xvNRfwy }, onStop()) 5_xvNRfwy }, function onStop()) 5_xvNRfwy }, function onStop()) 5_xvNRfwz }, function onStop() {}) 5_vvNRfvxvx5_wvNRgvx function read()5_wvNRgvx function read() []5_ wvNRgvx function read() {}5_! xvNRgwy" head(source)(function(element) {5_ "!yvNRgxz }, function onStop() {5_!#"zvNRgy{ }) 5_"$#zvNRgz| z|5_#%$yvNRg xz }, function onStop() {5_$&%yvNRg y{ y{5_%'&zvNRgy{ stops.push()5_&('xvNRgxz xz5_')(yvNRgxz buffer.push()5_(*){vNRg{} {}5_)+*w vNRg.wy wy5_*,+yvNRg6y{ y{5_+-,z vNRg9y{ open +5_,.-~vNRg;} read()5_-/.~ vNRg?} if (open) read()5_.0/~ vNRgB} if (!open) read()5_/10vNRgH5_021vNRgP1  function shift(source) {( source(function onElement(element) { buffer.push(element) shift(source) return false }, function onStop(error) { stops.push(error) }) } shift(source)5_132wvNRgcvx function read() {5_243vNRge2 }5_354;vNRgr3Q assert.deepEqual(stops, [ undefined, undefined, undefined ], 'stopped 3 times')5_465u"vNRgtv< var source = stack(list(1, 2, 3)), buffer = [], stops = []5_576uvNRgtv: var source = stack(function ()), buffer = [], stops = []5_687u*vNRgtvD var source = stack(function (next, stop)), buffer = [], stops = []5_798u,vNRgtwG var source = stack(function (next, stop) {}), buffer = [], stops = []5_8:9uvNRguw uw5_9;:v vNRguw next()5_:<;v vNRgvx vx5_;=<w vNRgvx next()5_<>=w vNRgwy wy5_=?>xvNRgwy setTimeout()5_>@?vNRg 5_?A@ vNRg if ()5_@BAvNRg if (stops.length === )5_ACBvNRg if (stops.length === 5)5_BDCvNRg if (stops.length === 5) 5_CED{vNRgz| !function read() {5_DFEvNRg }()5_EGF vNRg }(callback)5_FHGvNRg }(function())5_GIHvNRg }(function() {})5_HJI\vNRgD assert.deepEqual(buffer, [ 1, 2, 3 ], 'all elements were yielded')\ assert.deepEqual(stops, [ undefined, undefined, undefined, undefined ], 'stopped 3 times')}5_IKJ^vNRg }5_JLK^vNRg5_KML^vNRg 5_LNM^vNRg\ assert.deepEqual(stops, [ undefined, undefined, undefined, undefined ], 'stopped 3 times')5_MON^vNRg45_NPOx^vNRgwy setTimeout()5_OQPx^vNRgwy setTimeout(next, )5_PRQx^vNRgxz xz5_QSRy^vNRhxz setTimeout()5_RTSy^vNRhxz setTimeout(next, 4)5_SUTy^vNRh xz setTimeout(next, , 3, 4)5_TVUy^vNRh y{ y{5_UWVz ^vNRh5y{ next()5_VXWt9^vNRh*6su7 if (open) read()5_XZY%^vNRhJF assert.deepEqual(buffer, [ 1, 2, 3 ], 'all elements were yielded')5_Y[Z)^vNRhK8I assert.deepEqual(buffer, [ 1, 2, 5, 3 ], 'all elements were yielded')5_Z\[{^vNRhYz| }), buffer = [], stops = []5_[]\GvGNRh^^ assert.deepEqual(stops, [ undefined, undefined, undefined, undefined ], 'stopped 3 times')5_\^]GvGNRh_94 assert.deepEqual(stops, [ ], 'stopped 3 times')5_]_^IGvGNRhf:K assert.deepEqual(stops, [ nil, nil, nil, nil, nil ], 'stopped 3 times')5_^a_LGvGNRh< 5__b`atvNRit~ tv5_acbuvNRitv unction async(next, stop) {5_bdc|vNRi{}J var stream = join(list(async, list('|'), async, list('a', 'b'), list()))5_ced| vNRi={}K var stream = stack(list(async, list('|'), async, list('a', 'b'), list()))5_dfe| vNRi|~5_egf}vNRi|~5_fhgzvNRiz| z|5_gih{vNRiz| function 5_hjizvNRiz|5_ikj{vNRiz{5_jlk{vNRiz{ function 5_kml}vNRi} }5_lnm}vNRi|~ 5_mon~vNRi} function shift()5_npo~vNRi} function shift(next, stop)5_oqp~vNRi} function shift(next, stop) {}5_prq~vNRi~ ~5_qsr vNRi~ source()5_rts~vNRi}~ function shift(next, stop) {5_sut~vNRi}~ source(next, sto)5_tvu~vNRi}~ }5_uwv~vNRi}~5_vxw~vNRi}~, var source = stack(function (next, stop) {5_wyx~vNRi}~ next(1)5_xzy~vNRi}~ next(2)5_y{z~vNRi}~ setTimeout(next, 0, 3)5_z|{~vNRi}~ setTimeout(next, 3, 4)5_{}|~vNRi}~ next(5)5_|~}~vNRi}~" }), buffer = [], stops = [], nil5_}~~vNRi>}~5_~|KvNRj|~ buffer = {~K var source = stack(list(async, list('|'), async, list('a', 'b'), list()))5_}vNRj ?|~ buffer = []5_}vNRj@|~ buffer = [], stops5_}vNRj"A|~ buffer = [], stops = []5_vNRj6 buffer.push(element)5_ vNRj; source()5_vNRj> source(function())5_vNRj> source(function() {})5_vNRj@ source(function() {5_vNRjC5_!vNRjH$ head(source)(function(element) {5_vNRjK source(function(element) {5_ vNRjO strict(function(element) {5_vNRjR5_vNRjV buffer.push()5_ vNRjX 5_vNRj^ buffer.push()5_vNRja 5_vNRjg buffer.push([])5_vNRjh buffer.push())5_vNRjj buffer.push(buffer))5_vNRjn buffer.push(buffer)5_vNRjr buffer.push(elements)5_vNRjx })5_vNRj} }, function onStop())5_vNRj~ }, function onStop() {})5_vNRj }, function onStop() {5_vNRj })5_vNRj5_vNRj5_vNRj stops.push()5_vNRj }, function onStop() {5_|!vNRj{}L var source = stack(list(async, list('|'), async, list('a', 'b'), list())),5_|,vNRjC{}E var source = stack(list(list('|'), async, list('a', 'b'), list())),5_vNRj 5_ vNRj read()5_vNRj 5_ vNRk open ++5_vNRk E 5_ vNRkF if (open) read(callback)5_vNRk0H( if (stops.length === 5) callback()5_vNRm if (!open) read(callback)5_vNRm if (!open) callback)5_vNRm read(callback)5_vNRmI read(callback)5_ vNRmJ read()5_vNRn. read(callback)5_ vNRn8 if ()5_vNRn; if (open)5_vNRn= if (open) reason()5_vNRn@ if (open) read())5_vNRnC if (open) read(callback)5_ vNRnD" if (open) read(callback())5_vNRnL if (!open) callback()5_ vNRnOK if (!open) read(callback()5_vNRn[ 5_vNRnb else if ()5_vNRngM else if (open === -1)5_.vNRnL assert.deepEqual(buffer, [ 1, 2, 5, 3, 4 ], 'all elements were yielded')5_ vNRn? assert.deepEqual(buffer, [ [], 'all elements were yielded')5_!vNRnA assert.deepEqual(buffer, [ [''], 'all elements were yielded')5_&vNRnB assert.deepEqual(buffer, [ ['|'], 'all elements were yielded')5_+vNRnF assert.deepEqual(buffer, [ ['|'], [ 'a'all elements were yielded')5_vNRnO assert.deepEqual(stops, [ nil, nil, nil, nil, nil ], 'stopped as expected')5_vNRn7 nil, nil, nil, nil, nil ], 'stopped as expected')5_vNRnN- nil, nil, nil ], 'stopped as expected')5_vNRo5_vNRo5_vNRo 5_vNRo 5_vNRo"O console.log()5_vNRorP elements.push(elements)5_2vNRoQR assert.deepEqual(buffer, [ ['|'], [ 'a', 'b' ] ], 'all elements were yielded')5_ vNRoR nil5_|vNRpS{}> var source = stack(list(list('|'), list('a', 'b'), list())),5_vNRpV assert.deepEqual(buffer, [ ['|'], [ 'a', 'b' ], [] ], 'all elements were yielded')5_ vNRpTX assert.deepEqual(buffer, [ []['|'], [ 'a', 'b' ], [] ], 'all elements were yielded')5_)vNRp#U` assert.deepEqual(buffer, [ [1, 2, 3 ]['|'], [ 'a', 'b' ], [] ], 'all elements were yielded')5_|||vNRpP{}E var source = stack(async, list(list('|'), list('a', 'b'), list())),5_|||vNRpQ{}? var source = stack( list(list('|'), list('a', 'b'), list())),5_|||vNRpZW{}> var source = stack(list(list('|'), list('a', 'b'), list())),5_ ||vNRpY if (open) read(callback)5_'||vNRpZb assert.deepEqual(buffer, [ [1, 2, 3 ], ['|'], [ 'a', 'b' ], [] ], 'all elements were yielded')5_||vNRp[ 5_||vNRp\ nil, nil, nil, nil5_||vNRp nil, nil, nil, nil,5_||vNRp nil, nil, nil, nil,5_ ||vNRp] nil,5_||vNRp^ nil, nil5_||vNRp_ nil, nil,5_ ||vNRp nil5_||vNRp` nil, nil5_||vNRqa console.log(buffer)5_||vNRqc assert.deepEqual(buffer, [ [ 3, 2, 1 ], ['|'], [ 'a', 'b' ], [] ], 'all elements were yielded')5_||vNRqJ [ 3, 2, 1 ], ['|'], [ 'a', 'b' ], [] ], 'all elements were yielded')5_ ||vNRq = ['|'], [ 'a', 'b' ], [] ], 'all elements were yielded')5_||vNRq#6 [ 'a', 'b' ], [] ], 'all elements were yielded')5_ ||vNRq%( [] ], 'all elements were yielded')5_||vNRq'b5_K||vNRqkc nil, nil,  }) JL 5_ #N_Zd )var streamer = require('../streamer.js'),5_|%||vNRpTV{}E var source = stack(list(list('|'), async, list('a', 'b'), list())),5_|+||vNRpW{}K var source = stack(list(list('|'), async,async, list('a', 'b'), list())),5_ vNRk if (!open) read(callback)5_vNRkD var open = 15__a`vNRi  read(callback)5_xvNRfKxy xz setTimeout()5_yvNRfRxz setTimeout(function())5_yvNRfTxz setTimeout(function()5_yvNRfWxz setTimeout(function() {}5_yvNRfWxz setTimeout(function() { }5_zvNRfYy{5_zvNRfZy{ buffer.push(element)5_z||vNRfZ)z{ z| })5_|||vNRfw{} 5_|||vNRfw{}5_z}}vNRfx+z{ z| shift(source)5_;}}vNRf,; assert.deepEqual(stops, [ undefined ], 'stopped 3 times')5_t9}}vNRf-suBexports['test pull form stack on read'] = function(assert, done) {5_w}}vNRfvx function shift(source) {5_zvNRf%y{5_|vNRf!|} |~ shift()5_} vNRf$&|~ shift(source)5_wk0k7v7NRcvx function Stop(act) {5