VimŸUnDoåt ýÊSÊ[o…ixsü3Gv’“A€Û]Ïd¨î]>q)var streamer = require('../streamer.js'), #ââââN_YÂC_Ð 'ÿÿÿÿMî�˜õ >Ovar streamer = require('../streamer'), map = streamer.map, list = streamer.list5�_Ð ÿÿÿÿMî�šõ ?, map = streamer.map, list = streamer.list5�_Ð ÿÿÿÿMî�¢õ ?/ append = streamer.map, list = streamer.list5�_ÐÿÿÿÿMî�·õ ?4exports['test map empty'] = function(assert, done) {5�_ÐÿÿÿÿMî�ºõ ?7exports['test append empty'] = function(assert, done) {5�_ÐÿÿÿÿMî�½õ ?:exports['test append to empty'] = function(assert, done) {5�_ÐÿÿÿÿMî�¿õ ?7exports['test append empty'] = function(assert, done) {5�_Ð ÿÿÿÿMî�Éõ? test(assert, done, mapped, [])5�_Ð ÿÿÿÿMî�Ìõ?" test(assert, done, append(), [])5�_Ð "ÿÿÿÿMî�Îõ?( test(assert, done, append(list()), [])5�_Ð ÿÿÿÿMî�Øõ var empty = list()4 var mapped = map(empty, function onEach(element) {& assert.fail('mapper was executed') })5�_Ð ÿÿÿÿMî�Þõ<õ;5�_Ð  #ÿÿÿÿMî�÷õ <&var streamer = require('../streamer'),5�_Ð  ÿÿÿÿMî�nõ < "use strict";5�_ÐÿÿÿÿMî�oõ < "use strict';5�_Ð3 ÿÿÿÿMî�tõ24<M assert.equal(error.message, "Boom!", "error propagated to mapped stream")5�_Ð3&ÿÿÿÿMî�wõ24<M assert.equal(error.message, 'Boom!", "error propagated to mapped stream")5�_Ð3)ÿÿÿÿMî�}õ24<M assert.equal(error.message, 'Boom!', "error propagated to mapped stream")5�_Ð3KÿÿÿÿMî��õ24<M assert.equal(error.message, 'Boom!', 'error propagated to mapped stream")5�_Ð4LÿÿÿÿMî�ƒõ35<N assert.deepEqual(actual, expected, "all values were yielded before error")5�_Ð4'ÿÿÿÿMî�…õ35<N assert.deepEqual(actual, expected, "all values were yielded before error')5�_Ð:ÿÿÿÿMî�‰õ9;< require("test").run(exports);5�_Ð: ÿÿÿÿMî�Š õ9;< require("test').run(exports);5�_ÐÿÿÿÿMõreturn5�_ÐÿÿÿÿvMõ?}õ=õ<õ;5�_Ð"ÿÿÿÿvMî“Å õ??exports['test append empty streams'] = function(assert, done) {5�_Ð!ÿÿÿÿvMî“É õ?0 test(assert, done, append(list(), list()), [])5�_Ð2ÿÿÿÿvMî“Í õ?4 test(assert, done, append(list(1, 2), list()), [])5�_ÐÿÿÿÿvMî“ÓõAõ@õ?5�_ÐÿÿÿÿvMî“×õC7exports['test append empty'] = function(assert, done) {5�_Ð %ÿÿÿÿvMî“ÝõC8 test(assert, done, append(list(1, 2), list()), [1, 2])5�_Ð! )ÿÿÿÿvMî“áõC4 test(assert, done, append(list(), list()), [1, 2])5�_Ð "!2ÿÿÿÿvMî“åõC8 test(assert, done, append(list(), list(3, 4)), [1, 2])5�_Ð!#"5ÿÿÿÿvMî“èõC8 test(assert, done, append(list(), list(3, 4)), [3, 2])5�_Ð"$#ÿÿÿÿvMî“éõDõC5�_Ð#%$ÿÿÿÿvMî“öõDreturn5�_Ð$&%ÿÿÿÿvMî“úõ5�_Ð%'&ÿÿÿÿvMî”õ var numbers = list(1, 2, 3, 4)5�_Ð&('ÿÿÿÿvMî”õN var doubled = map(numbers, function onElement(number) { return number * 2 })5�_Ð')(ÿÿÿÿvMî”õA+ test(assert, done, doubled, [2, 4, 6, 8])5�_Ð(*)ÿÿÿÿvMî”õA+ test(assert, done, append() [2, 4, 6, 8])5�_Ð)+*!ÿÿÿÿvMî” õA1 test(assert, done, append(list()) [2, 4, 6, 8])5�_Ð*,+&ÿÿÿÿvMî”õA5 test(assert, done, append(list(1, 2)) [2, 4, 6, 8])5�_Ð+-,ÿÿÿÿvMî”õA5exports['test number map'] = function(assert, done) {5�_Ð,.-ÿÿÿÿvMî”õA;exports['test append 3 streams'] = function(assert, done) {5�_Ð-/.ÿÿÿÿvMî”$õA;exports['test append 2 streams'] = function(assert, done) {5�_Ð.0/ÿÿÿÿvMî”'õB õA5�_Ð/10ÿÿÿÿ(v(Mî”.õB7 test(assert, done, append(list(1, 2), ) [2, 4, 6, 8])5�_Ð021ÿÿÿÿ(v(Mî”.õB# test(assert, done, [2, 4, 6, 8])5�_Ð132ÿÿÿÿ(v(Mî”1õB var stream = 5�_Ð243"ÿÿÿÿ(v(Mî”4õB# var stream = append(list(1, 2), )5�_Ð354(ÿÿÿÿ(v(Mî”6õB) var stream = append(list(1, 2), list())5�_Ð465/ÿÿÿÿ(v(Mî”8õB1 var stream = append(list(1, 2), list(), list())5�_Ð5760ÿÿÿÿ(v(Mî”:õB3 var stream = append(list(1, 2), list(), list(''))5�_Ð6872ÿÿÿÿ(v(Mî”;õB4 var stream = append(list(1, 2), list(), list('a'))5�_Ð7985ÿÿÿÿ(v(Mî”<õB8 var stream = append(list(1, 2), list(), list('a', ''))5�_Ð8:98ÿÿÿÿ(v(Mî”AõB9 var stream = append(list(1, 2), list(), list('a', 'b'))5�_Ð9;:ÿÿÿÿ(v(Mî”GõB* test(assert, done, stream, [2, 4, 6, 8])5�_Ð:<;!ÿÿÿÿ(v(Mî”HõB* test(assert, done, stream, [1, 4, 6, 8])5�_Ð;=<!ÿÿÿÿ(v(Mî”JõB* test(assert, done, stream, [1, ,, 6, 8])5�_Ð<>=$ÿÿÿÿ(v(Mî”KõB* test(assert, done, stream, [1, 2, 6, 8])5�_Ð=?>%ÿÿÿÿ(v(Mî”LõB* test(assert, done, stream, [1, 2, ', 8])5�_Ð>@?(ÿÿÿÿ(v(Mî”QõB, test(assert, done, stream, [1, 2, 'a', 8])5�_Ð?A@(ÿÿÿÿ(v(Mî”RõB+ test(assert, done, stream, [1, 2, 'a',8])5�_Ð@BA(ÿÿÿÿ(v(Mî”SõB* test(assert, done, stream, [1, 2, 'a',])5�_ÐADB*ÿÿÿÿ(v(Mî”UõB- test(assert, done, stream, [1, 2, 'a', ''])5�_ÐBECDÿÿÿÿ(v(Mî”gõ Cõ B5�_ÐDFEÿÿÿÿ(v(Mî”uõreturn5�_ÐEGFÿÿÿÿ(v(Mî”yõ B@exports['test map with async stream'] = function(assert, done) {5�_ÐFHGÿÿÿÿ(v(Mî”}õ BCexports['test append with async stream'] = function(assert, done) {5�_ÐGIHÿÿÿÿ(v(Mõ BEexports['test append sync / async stream'] = function(assert, done) {5�_ÐHJI&ÿÿÿÿ(v(Mõ BCexports['test append sync async stream'] = function(assert, done) {5�_ÐIKJÿÿÿÿ(v(Mõ BDexports['test append sync async streams'] = function(assert, done) {5�_ÐJLK ÿÿÿÿ(v(Mõ!B function stream(next, stop) {5�_ÐKML'ÿÿÿÿ(v(Mõ')C õ')B5�_ÐLNM(ÿÿÿÿ(v(Mî”™õ')C 5�_ÐMON)8ÿÿÿÿ(v(Mõ(*C8 var mapped = map(stream, function(x) { return x + 1 })5�_ÐNPO) ÿÿÿÿ(v(Mõ(*C var stream()5�_ÐOQP)ÿÿÿÿ(v(Mî”§õ(*C var stream(async, list())5�_ÐPRQ)(ÿÿÿÿ(v(Mõ(*C* var stream(async, list(), async, list())5�_ÐQSR))ÿÿÿÿ(v(Mõ(*C, var stream(async, list(), async, list(''))5�_ÐRTS)+ÿÿÿÿ(v(Mõ(*C- var stream(async, list(), async, list('a'))5�_ÐSUT).ÿÿÿÿ(v(Mî”´õ(*C1 var stream(async, list(), async, list('a', ''))5�_ÐTVU! ÿÿÿÿ(v(Mî”·õ "C var x = 55�_ÐUWV*ÿÿÿÿ(v(Mî”Íõ)+C/ test(assert, done, mapped, [ 6, 5, 4, 3, 2 ])5�_ÐVXW) ÿÿÿÿ(v(Mî”Ñõ(*C2 var stream(async, list(), async, list('a', 'b'))5�_ÐWYX(ÿÿÿÿ(v(Mî”âõ')Dõ(*Dõ(*C5�_ÐXZY*ÿÿÿÿ(v(Mî”íõ)+C/ test(assert, done, stream, [ 6, 5, 4, 3, 2 ])5�_ÐY[Z*"ÿÿÿÿ(v(Mî”ïõ)+C/ test(assert, done, stream, [ 3, 5, 4, 3, 2 ])5�_ÐZ\[*%ÿÿÿÿ(v(Mî”ñõ)+C/ test(assert, done, stream, [ 3, 2, 4, 3, 2 ])5�_Ð[]\*(ÿÿÿÿ(v(Mî”ôõ)+C/ test(assert, done, stream, [ 3, 2, 1, 3, 2 ])5�_Ð\^]*,ÿÿÿÿ(v(Mî”öõ)+C/ test(assert, done, stream, [ 3, 2, 1, 3, 2 ])5�_Ð]_^*2ÿÿÿÿ(v(Mî”øõ)+C6 test(assert, done, stream, [ 3, 2, 1, 3, 2, 1, '' ])5�_Ð^`_*4ÿÿÿÿ(v(Mî”ùõ)+C7 test(assert, done, stream, [ 3, 2, 1, 3, 2, 1, 'a' ])5�_Ð_a`*7ÿÿÿÿ(v(Mî”úõ)+C; test(assert, done, stream, [ 3, 2, 1, 3, 2, 1, 'a', '' ])5�_Ð`ba,ÿÿÿÿ(v(Mî”üõ,.Dõ,.C5�_Ðacb-ÿÿÿÿ(v(Mî•õ,.Dreturn5�_Ðbdc- ÿÿÿÿ(v(Mî•õ,.D exports0''5�_Ðced-ÿÿÿÿ(v(Mî• õ,.D exports[]5�_Ðdfe- ÿÿÿÿ(v(Mî• õ,.D exports['']5�_Ðegf-!ÿÿÿÿ(v(Mî•õ,.D!exports['test append & reappend']5�_Ðfhg--ÿÿÿÿ(v(Mî•õ,.D.exports['test append & reappend'] = function()5�_Ðgih-:ÿÿÿÿ(v(Mî•õ,.D:exports['test append & reappend'] = function(assert, done)5�_Ðhji-<ÿÿÿÿ(v(Mî•õ,/D=exports['test append & reappend'] = function(assert, done) {}5�_Ðikj.ÿÿÿÿ(v(Mî• õ.0E5�_Ðjlk-ÿÿÿÿ *<vÿÿÿMî•'õ-:G õ-/F5�_Ðkml9ÿÿÿÿ *<vÿÿÿMî•)!õ895�_Ðlnm7,ÿÿÿÿ *<vÿÿÿMî•."õ68Q; var stream = append(async, list(), async, list('a', 'b'))5�_Ðmon7ÿÿÿÿ *<vÿÿÿMî•1õ79R õ79Q5�_Ðnpo8ÿÿÿÿ *<vÿÿÿMî•6õ79R stream = append()5�_Ðoqp8ÿÿÿÿ *<vÿÿÿMî•;õ79R! stream = append(stream, list())5�_Ðprq8 ÿÿÿÿ *<vÿÿÿMî•<õ79R# stream = append(stream, list(''))5�_Ðqsr8$ÿÿÿÿ *<vÿÿÿMî•?#õ79R% stream = append(stream, list('||'))5�_Ðrts9(ÿÿÿÿ9(90v0Mî•Oõ8:R< test(assert, done, stream, [ 3, 2, 1, 3, 2, 1, 'a', 'b' ])5�_Ðsut90ÿÿÿÿ99/v/Mî•Wõ8:R3 test(assert, done, stream, [ 3, 2, 1, 'a', 'b' ])5�_Ðtvu93ÿÿÿÿ99/v/Mî•Yõ8:R7 test(assert, done, stream, [ 3, 2, 1, 'a', 'b', '' ])5�_Ðuwv96ÿÿÿÿ99/v/Mî•Z$õ8:R9 test(assert, done, stream, [ 3, 2, 1, 'a', 'b', '||' ])5�_Ðvxw:ÿÿÿÿ99/v/Mî•_%õ:=Sõ:<R5�_Ðwyx<ÿÿÿÿ99/v/Mî•øõ;<return5�_Ðxzy<ÿÿÿÿ99/v/Mî•ù&õ;<5�_Ðy{z=ÿÿÿÿ99/v/Mî– 'õ<>R function stream(next, stop) {5�_Ðz|{Dÿÿÿÿ99/v/Mî–õEG var stream = appendõDGS õDFR5�_Ð{}|Fÿÿÿÿ99/v/Mî–õEGT var stream = append()5�_Ð|~}F"ÿÿÿÿ99/v/Mî–%õEGT$ var stream = append(async, list())5�_Ð}~Fÿÿÿÿ99/v/Mî–*õEGT( var stream = append(async, list(1, 2))5�_Ð~€Fÿÿÿÿ99/v/Mî–4õEGT2 var stream = append(list('>', async, list(1, 2))5�_Ð�€F2ÿÿÿÿ99/v/Mî–8(õEGT3 var stream = append(list('>'), async, list(1, 2))5�_Ѐ‚�Gÿÿÿÿ99/v/Mî–<õFG8 var mapped = map(stream, function(x) { return x * x })5�_Ð�ƒ‚Gÿÿÿÿ99/v/Mî–=õFG var expected = [ 9, 4, 1]5�_Ђ„ƒGÿÿÿÿ99/v/Mî–>õFG var actual = []5�_Ѓ…„<ÿÿÿÿ99/v/Mî–A)õ<>R õ<>Q5�_Є†…H"ÿÿÿÿ99/v/Mî–J*õGIRD mapped(function next(x) { actual.push(x) }, function stop(error) {5�_Ð…‡†Hÿÿÿÿ99/v/Mî–W+õGIRD mapped(function next(x) { buffer.push(x) }, function stop(error) {5�_Іˆ‡IDÿÿÿÿ99/v/Mî–_,õHJRM assert.equal(error.message, 'Boom!', 'error propagated to mapped stream')5�_Ї‰ˆIKÿÿÿÿ99/v/Mî–i-õHJRM assert.equal(error.message, 'Boom!', 'error propagated to result stream')5�_ÐˆŠ‰Jÿÿÿÿ99/v/Mî–võIKRN assert.deepEqual(actual, expected, 'all values were yielded before error')5�_Љ‹ŠJ%ÿÿÿÿ99/v/Mî–õIKRN assert.deepEqual(buffer, expected, 'all values were yielded before error')5�_ЊŒ‹J!ÿÿÿÿ99/v/Mî–ƒ.õILRH assert.deepEqual(buffer, [], 'all values were yielded before error')5�_Ћ�ŒJÿÿÿÿ99/v/Mî–ŠõIKS assert.deepEqual(buffer, [],5�_ÐŒŽ�J ÿÿÿÿ99/v/Mî–ŒõIKS# assert.deepEqual(buffer, [ ''],5�_Ð��ŽJ ÿÿÿÿ99/v/Mî–�õIKS# assert.deepEqual(buffer, [ ''],5�_ÐŽ��J"ÿÿÿÿ99/v/Mî–ŽõIKS$ assert.deepEqual(buffer, [ '>'],5�_Ð�‘�J%ÿÿÿÿ99/v/Mî–žõIKS( assert.deepEqual(buffer, [ '>', ''],5�_Ð�’‘J+ÿÿÿÿ99/v/Mî–¢/õIKS- assert.deepEqual(buffer, [ '>', 3, 2, 1],5�_Б“’NÿÿÿÿN2êõOaUõNQTõNPS5�_Ð’”“PÿÿÿÿN2ï0õOQeõACt if (false !== next(x--))setTimeout(onTimeout, 0)õBDt setTimeout(onTimeout, 0)5�_ÐÒÔÓ2ÿÿÿÿUZEvEN5Ãõ13s next(x--)5�_ÐÓÕÔ2ÿÿÿÿUZEvEN5Êõ13s if (false !== next(x--)5�_ÐÔÙÕ2ÿÿÿÿUZEvEN5Êõ13s if (false !== next(x--){}5�_ÐÕÚØÙ2ÿÿÿÿ22N6.õ14s if (false !== next(x--))5�_ÐÙÛÚ3ÿÿÿÿ22N63õ23 5�_ÐÚÜÛ3ÿÿÿÿ22N64?õ13s if (false !== next(x--))setTimeout(onTimeout, 0)õ24s setTimeout(onTimeout, 0)5�_ÐÛÝÜ$ÿÿÿÿ22N6;õ#%r next(x--)5�_ÐÜÞÝ$ÿÿÿÿ22N6Gõ#%r if (false !== next(x--)5�_ÐÝßÞ%ÿÿÿÿ22N6HAõ#%r if (false !== next(x--))setTimeout(onTimeout, 0)õ$&r setTimeout(onTimeout, 0)5�_ÐÞàßÿÿÿÿNO•zõqˆ(typeof define === "undefined" ? function ($) { $(require, exports, module) } : define)(function (require, exports, module, undefined) {5�_ÐßáàqÿÿÿÿNO•|Bõp})5�_Ðàâá #ÿÿÿÿN_Y¿õ q)var streamer = require('../streamer.js'),5�_Ðáâ $ÿÿÿÿN_YÁCõ q.var streamer = require('../streamer/core.js'),5�_ÐÕ×ÙØ2ÿÿÿÿ22N6'õ23s5�_ÐÕÖØ×2ÿÿÿÿ22N6 õ23s5�_ÐÕ×Ö3ÿÿÿÿUZEvEN5Öõ24s setTimeout(onTimeout, 05�_ÐBDC*ÿÿÿÿ(v(Mî”\õB- test(assert, done, stream, [1, 2, 'a', ''])5�çª