VimŸUnDoåÍ]h ]›Â�™¼CŒ]¾Eí 7ƒx7Úc`\�s)var streamer = require('../streamer.js'), #nnnnN_YíB_Ð ÿÿÿÿNP3Ìõ s0 merge = streamer.merge, list = streamer.list5�_Ð ÿÿÿÿNP3Ïõ s/ join = streamer.merge, list = streamer.list5�_ÐÿÿÿÿNP3Ôõs5 test(assert, done, merge(list(list(), list())), [])5�_ÐÿÿÿÿNP3ÙõsE test(assert, done, merge(list(list(), list(1, 2), list())), [1, 2])5�_ÐÿÿÿÿNP3Þõs6 var stream = merge(list(list(1, 2), list('a', 'b')))5�_ÐÿÿÿÿNP3èõs1 stream = merge(list(list('>'), stream, list()))5�_ÐÿÿÿÿvNP3õõ sHexports['test merge stream of empty streams'] = function(assert, done) {5�_Ð ÿÿÿÿvNP3øõsBexports['test merge empty & non-empty'] = function(assert, done) {5�_Ð ÿÿÿÿvNP3üõs7exports['test merge merged'] = function(assert, done) {5�_Ð ÿÿÿÿvNP3þõs6exports['test join merged'] = function(assert, done) {5�_Ð ÿÿÿÿvNP4õsEexports['test merge sync & async streams'] = function(assert, done) {5�_Ð %ÿÿÿÿvNP4õ$&s9 var stream = merge(list(async, list(), list('a', 'b')))5�_Ð  %'ÿÿÿÿvNP4õ$&s8 var stream = join(list(async, list(), list('a', 'b')))5�_Ð %-ÿÿÿÿvNP4 õ$&s> var stream = join(list(async, list(), async list('a', 'b')))5�_Ð%%ÿÿÿÿvNP4$õ$&s? var stream = join(list(async, list(), async, list('a', 'b')))5�_Ð%&ÿÿÿÿvNP4&õ$&sA var stream = join(list(async, list(''), async, list('a', 'b')))5�_Ð&ÿÿÿÿvNP42õ%'s3 test(assert, done, stream, [ 'a', 'b', 3, 2, 1 ])5�_Ð&+ÿÿÿÿvNP4;õ%'s> test(assert, done, stream, [ 3, 2, 1, '|'a', 'b', 3, 2, 1 ])5�_Ð&>ÿÿÿÿ&>&FvFNP4Eõ%'sJ test(assert, done, stream, [ 3, 2, 1, '|', 3, 2, 1, 'a', 'b', 3, 2, 1 ])5�_Ð%@ÿÿÿÿ&>&FvFNP4Gõ$&sB var stream = join(list(async, list('|'), async, list('a', 'b')))5�_Ð)ÿÿÿÿ&>&FvFNP4Qõ(*sCexports['test merge with broken stream'] = function(assert, done) {5�_Ð3ÿÿÿÿ&>&FvFNP4_õ24s9 var stream = merge(list(list('>'), async, list(1, 2) ))5�_Ð6$ÿÿÿÿ6$6(v(NP4›õ57s4 assert.deepEqual(buffer, [ '>', 1, 2, 3, 2, 1 ],5�_Ð6$ÿÿÿÿ6$6(v(NP4›õ57s/ assert.deepEqual(buffer, [ '>', 3, 2, 1 ],5�_Ð<ÿÿÿÿ6$6(v(NP4¨ õ;=sHexports['test merge async stream of streams'] = function(assert, done) {5�_ÐNÿÿÿÿ6$6(v(NP4ÃõMOsL test(assert, done, merge(source), [1, 2, 'a', 3, 'a', 2, 'a', 1, 3, 2, 1])5�_ÐN*ÿÿÿÿ6$6(v(NP5õMOsK test(assert, done, join(source), [1, 2, 'a', 3, 'a', 2, 'a', 1, 3, 2, 1])5�_ÐN1ÿÿÿÿ6$6(v(NP5 õMOsR test(assert, done, join(source), [1, 2, 3, 2, 1'a', 3, 'a', 2, 'a', 1, 3, 2, 1])5�_ÐN:ÿÿÿÿ6$6(v(NP5$õMOsT test(assert, done, join(source), [1, 2, 3, 2, 1, 'a', 3, 'a', 2, 'a', 1, 3, 2, 1])5�_ÐNBÿÿÿÿ6$6(v(NP5.õMOs\ test(assert, done, join(source), [1, 2, 3, 2, 1, 'a', 3, 3, 2, 1 'a', 2, 'a', 1, 3, 2, 1])5�_Ð NLÿÿÿÿ6$6(v(NP53õMOs] test(assert, done, join(source), [1, 2, 3, 2, 1, 'a', 3, 3, 2, 1, 'a', 2, 'a', 1, 3, 2, 1])5�_Ð! N[ÿÿÿÿN[NcvcNP5=õMOsf test(assert, done, join(source), [1, 2, 3, 2, 1, 'a', 3, 3, 2, 1, 'a', 2, 3, 2, 1, 'a', 1, 3, 2, 1])5�_Ð "!N[ÿÿÿÿN[NcvcNP5E õMOs] test(assert, done, join(source), [1, 2, 3, 2, 1, 'a', 3, 3, 2, 1, 'a', 2, 3, 2, 1, 'a', 1])5�_Ð!#"NCÿÿÿÿN[NcvcNP5’õMOs^ test(assert, done, join(source), [1, 2, 3, 2, 1, 'a', 3, 3, 2, 1, 'a', 2, 3, 2, 1, 'a', 1 ])5�_Ð"$#N3ÿÿÿÿN[NcvcNP5—õMOsU test(assert, done, join(source), [1, 2, 3, 2, 1, 'a', 3, 'a', 2, 3, 2, 1, 'a', 1 ])5�_Ð#%$GÿÿÿÿN[NcvcNP5 õFHs next(list(1, 2))5�_Ð$&%GÿÿÿÿN[NcvcNP5¢õFHs next(list('1, 2))5�_Ð%'&GÿÿÿÿN[NcvcNP5¤õFHs next(list('1', 2))5�_Ð&('GÿÿÿÿN[NcvcNP5¥õFHs next(list('1', '2))5�_Ð')(N$ÿÿÿÿN[NcvcNP5©õMOsL test(assert, done, join(source), [1, 2, 'a', 3, 'a', 2, 3, 2, 1, 'a', 1 ])5�_Ð(*)N%ÿÿÿÿN[NcvcNP5ªõMOsM test(assert, done, join(source), [ 1, 2, 'a', 3, 'a', 2, 3, 2, 1, 'a', 1 ])5�_Ð)+*N'ÿÿÿÿN[NcvcNP5«õMOsN test(assert, done, join(source), [ '1, 2, 'a', 3, 'a', 2, 3, 2, 1, 'a', 1 ])5�_Ð*,+N*ÿÿÿÿN[NcvcNP5­õMOsO test(assert, done, join(source), [ '1', 2, 'a', 3, 'a', 2, 3, 2, 1, 'a', 1 ])5�_Ð+-,N,ÿÿÿÿN[NcvcNP5®õMOsP test(assert, done, join(source), [ '1', '2, 'a', 3, 'a', 2, 3, 2, 1, 'a', 1 ])5�_Ð,.-N?ÿÿÿÿN?NGvGNP5¶õMOsQ test(assert, done, join(source), [ '1', '2', 'a', 3, 'a', 2, 3, 2, 1, 'a', 1 ])5�_Ð-/.NEÿÿÿÿN?NGvGNP5¹õMOsH test(assert, done, join(source), [ '1', '2', 'a', 3, 'a', 2, 'a', 1 ])5�_Ð.1/NIÿÿÿÿN?NGvGNP5Á õMOsS test(assert, done, join(source), [ '1', '2', 'a', 3, 'a', 2, 'a', 1, , 3, 2, 1 ])5�_Ð/201QÿÿÿÿN?NGvGNP5Ì õPRs9&+ÿÿÿÿ&&JvÿÿÿNP=#õ%'tJ var stream = join(list(async, list('|'), async, list('a', 'b'), list()))5�_Ð9?<>&5ÿÿÿÿ&5&<v<NP=]õ%'t? var stream = join(list(async, async, list('a', 'b'), list()))5�_Ð>@?& ÿÿÿÿ&5&<v<NP=}õ%'t7 var stream = join(list(async, async, list('a', 'b')))5�_Ð?A@&'ÿÿÿÿ&5&<v<NP=�õ%'tB var stream = join(list(async, list('!'), async, list('a', 'b')))5�_Ð@BA&@ÿÿÿÿ&5&<v<NP=“ õ%'tB var stream = join(list(async, list('|'), async, list('a', 'b')))5�_ÐACBÿÿÿÿ&5&<v<NPìÄ!õ console.log('!!')5�_ÐBDC ÿÿÿÿ%5%<v<NRAãõ sGexports['test join stream of empty streams'] = function(assert, done) {5�_ÐCED ÿÿÿÿ%5%<v<NRAå"õsAexports['test join empty & non-empty'] = function(assert, done) {5�_ÐDFE ÿÿÿÿ%5%<v<NRAÿ#õs6exports['test join joined'] = function(assert, done) {5�_ÐEGFÿÿÿÿ%5%<v<NRD‹õ var x = 35�_ÐFHG!ÿÿÿÿ$5$<v<NRD�õ "r }, 0)5�_ÐGIH! ÿÿÿÿ$5$<v<NRD�õ "r }, 0, x)5�_ÐHJI"ÿÿÿÿ$5$<v<NRD“õr% setTimeout(function onTimeout() {5�_ÐIKJ 6ÿÿÿÿ$5$<v<NRDšõ!r7 if (false !== next(x--)) setTimeout(onTimeout, 0)5�_ÐJLK 8ÿÿÿÿ$5$<v<NRD õ!r: if (false !== next(x--)) setTimeout(onTimeout, 0, x)5�_ÐKML ÿÿÿÿ$5$<v<NRD£%õ!r< if (false !== next(x--)) setTimeout(onTimeout, 0, --x)5�_ÐLNM&ÿÿÿÿ$$GvGNRF3'õ&)sõ&(r5�_ÐMON(ÿÿÿÿ$$GvGNRF<õ')treturn5�_ÐNPO(ÿÿÿÿ$$GvGNRF<õ')tren5�_ÐOQP(ÿÿÿÿ$$GvGNRF=(õ'(ren5�_ÐPRQ) ÿÿÿÿ$$GvGNRF@)õ(*sBexports['test join with broken stream'] = function(assert, done) {5�_ÐQSR< ÿÿÿÿ$$GvGNRFE*õ;=sGexports['test join async stream of streams'] = function(assert, done) {5�_ÐRWSQ ÿÿÿÿ$$GvGNRFJ0õPRs>>>>>>>')5�_ÐZ\[ÿÿÿÿ%%HvHNRKè3õ console.log('>>>>>>>>', x)5�_Ð[]\ÿÿÿÿ"vNRWZõt õs5�_Ð\^]ÿÿÿÿ#vNRW]õt console.log()5�_Ð]c^ÿÿÿÿ#vNRW]8õt console.log('')5�_Ð^d_c ÿÿÿÿ%JvJNRZñõt7exports['-test join joined'] = function(assert, done) {5�_Ðced ÿÿÿÿ%JvJNRZóõtBexports['-test join empty & non-empty'] = function(assert, done) {5�_Ðdfe ÿÿÿÿ%JvJNRZô9õ tHexports['-test join stream of empty streams'] = function(assert, done) {5�_Ðehf* ÿÿÿÿ%JvJNRZý<õ)+tCexports['-test join with broken stream'] = function(assert, done) {5�_ÐfighR ÿÿÿÿ%JvJNR[=õQSt=exports['-test interrupt joined stream'] = function(assert) {5�_Ðhji= ÿÿÿÿ%JvJNR[->õ<>tHexports['-test join async stream of streams'] = function(assert, done) {5�_ÐikjJÿÿÿÿKK&v&NR[¯õIKt* if (!x) return next(async) || stop()5�_ÐjlkJ$ÿÿÿÿKK&v&NR[²õIKt+ if (!x) return (next(async) || stop()5�_ÐkmlJ)ÿÿÿÿKK&v&NR[³@õIKt) if (!x) return (next(async), stop()5�_ÐlnmÿÿÿÿKK&v&NR\Aõ console.log('>>>>>>')5�_Ðmn #ÿÿÿÿN_YìBõ s)var streamer = require('../streamer.js'),5�_Ðfhg= ÿÿÿÿ%JvJNR[;õ<>tGexports['test join async stream of streams'] = function(assert, done) {5�_Ð^`c_%*ÿÿÿÿ#vNRW~õ$&tQ var stream = join(list(async, list('|'), list() async, list('a', 'b'), list()))5�_Ð_b`%0ÿÿÿÿ#vNRW5õ$&tT var stream = join(list(async, list('|'), list(1,2) async, list('a', 'b'), list()))5�_Ð`abÿÿÿÿ"vNRW©7õ5�_Ð`ba%4ÿÿÿÿ#vNRWƒ6õ$&tU var stream = join(list(async, list('|'), list(1,2), async, list('a', 'b'), list()))5�_ÐSVWT$ÿÿÿÿ$$GvGNRHõ#%sK var stream = join(list( async, list('|'), async, list('a', 'b'), list()))5�_ÐTUV$'ÿÿÿÿ$$GvGNRHþ/õ#%sK var stream = join(list( async, list('u'), async, list('a', 'b'), list()))5�_ÐTVU$Iÿÿÿÿ$$GvGNRH -õ#%sL var stream = join(list( async, list('|'), async, list('a', 'b'), list() ))5�_Ð9=:><&'ÿÿÿÿ&'&5v5NP=Fõ%'t0 var stream = join(list(async, async, list()))5�_Ð<=&'ÿÿÿÿ&'&5v5NP=Gõ%'t/ var stream = join(list(async, async, list()))5�_Ð9;<:&'ÿÿÿÿ&'&<v<NP=:õ%'t) var stream = join(list(async, async, ))5�_Ð:;&'ÿÿÿÿ&'&<v<NP=;õ%'t' var stream = join(list(async, async))5�_Ð354$+ÿÿÿÿ$+$1v1NP:xõ#%r? var stream = join(list(async, async, list('a', 'b'), list()))5�_Ð/10QÿÿÿÿN?NGvGNP5ÊõPRs8exports['test interrupt jo stream'] = function(assert) {5�çª