VimŸUnDoåÞÍaÖ�O-ZŒ§Ôíµ¢Œ•|e åç'² qB`ÉÅQ)var streamer = require('../streamer.js'), #¸¸¸¸N_Z__ÐÿÿÿÿM쯒õ+5�_Ð+ÿÿÿÿM쯔õ*+5�_Ð*ÿÿÿÿM쯕õ)*5�_Ð ÿÿÿÿM쯠õ )&var list = require('../streamer').list5�_Ð *ÿÿÿÿM쯢õ )*var streamer = require('../streamer').list5�_ÐÿÿÿÿMì¯Æõ) test(assert, [])5�_Ð  ÿÿÿÿMì¯Îõ) sequence = 5�_Ð ÿÿÿÿMì¯Øõ) var numbers = list()5�_Ð ÿÿÿÿMì¯Øõ) var numbers = list('')5�_Ð ÿÿÿÿMì¯Þõ* õ)5�_Ð ÿÿÿÿMì¯êõ* var doubled = map()5�_Ð  ÿÿÿÿMì¯íõ* var doubled = map(number, )5�_Ð ÿÿÿÿMì¯ïõ* var doubled = map(numbers, )5�_ÐÿÿÿÿMì¯óõ* var doubled = map(number )5�_Ð2ÿÿÿÿMì¯úõ*3 var doubled = map(numbers, function onElement() )5�_Ð3ÿÿÿÿMì¯úõ*5 var doubled = map(numbers, function onElement() {})5�_Ð0ÿÿÿÿMì¯þõ+3 var doubled = map(numbers, function onElement() {5�_Ð.ÿÿÿÿMì° õ, õ+5�_ÐÿÿÿÿMì°õ, var isEnded = true5�_ÐÿÿÿÿMì°*õ- õ,5�_ÐÿÿÿÿMì°5õ-9 var doubled = map(numbers, function onElement(number) {return number * 2õ- return number * 25�_ÐÿÿÿÿMì°7õ,K var doubled = map(numbers, function onElement(number) { return number * 2})õ, })5�_ÐÿÿÿÿMì°Põ+/exports['test empty list'] = function(assert) {5�_ÐÿÿÿÿMì°Sõ,õ+5�_Ð ÿÿÿÿMì°Võ, exports0''5�_ÐÿÿÿÿMì°Xõ, exports[]5�_Ð ÿÿÿÿMì°Xõ, exports['']5�_ÐÿÿÿÿMì°]õ,exports['test map empy']5�_ÐÿÿÿÿMì°^õ,exports['test map empty']5�_Ð %ÿÿÿÿMì°`õ,&exports['test map empty'] = function()5�_Ð! ,ÿÿÿÿMì°aõ,,exports['test map empty'] = function(assert)5�_Ð "!.ÿÿÿÿMì°bõ,/exports['test map empty'] = function(assert) {}5�_Ð!#"ÿÿÿÿMì°cõ. õ-5�_Ð"$#ÿÿÿÿMì°jõ/ õ.5�_Ð#%$ÿÿÿÿMì°nõ/ map()5�_Ð$&%ÿÿÿÿMì°wõ/ map(empty, function onEach())5�_Ð%'&%ÿÿÿÿMì°yõ/& map(empty, function onEach(element))5�_Ð&(''ÿÿÿÿMì°zõ/) map(empty, function onEach(element) {})5�_Ð')(ÿÿÿÿMì°{õ05�_Ð(*)ÿÿÿÿMì°}õ1 var empty = list()5�_Ð)+*ÿÿÿÿMì°‰õ1 var empty = list(), isNexted5�_Ð*,+ÿÿÿÿMì°�õ1) var empty = list(), isNexted, isStopped5�_Ð+-,1ÿÿÿÿMì°‘õ11 var empty = list(), isNexted = false, isStopped5�_Ð,.-ÿÿÿÿMì°—õ15�_Ð-/.ÿÿÿÿMì° õ1 })5�_Ð.0/ÿÿÿÿMì°¦õ1 }, function onStop())5�_Ð/10ÿÿÿÿMì°¨õ1 }, function onStop(errror))5�_Ð021ÿÿÿÿMì°¨õ1 }, function onStop(errror) {})5�_Ð132ÿÿÿÿMì°ªõ3 õ25�_Ð243ÿÿÿÿMì°°õ3 assert.equal()5�_Ð354ÿÿÿÿMì°°õ3 assert.equal('')5�_Ð465ÿÿÿÿMì°³õ3 assert.equal(error, '')5�_Ð576$ÿÿÿÿMì°¹õ3& assert.equal(error, undefined, '')5�_Ð697ÿÿÿÿMì°Æõ3 }, function onStop(errror) {5�_Ð7:89ÿÿÿÿMì°Þõ!4 õ!35�_Ð9;: ÿÿÿÿMì°âõ!4 assert.ok()5�_Ð:<; ÿÿÿÿMì°æõ!4 assert.ok(isStopped, "")5�_Ð;=< (ÿÿÿÿMì°éõ "5 õ "45�_Ð<>=! ÿÿÿÿMì°ìõ "5 assert.ok()5�_Ð=?>! ÿÿÿÿMì°íõ "5 assert.ok("")5�_Ð>@?!ÿÿÿÿMì°ó õ "5 assert.ok(!isNexted, "")5�_Ð?A@!3ÿÿÿÿMì°þ õ "55 assert.ok(!isNexted, "map function was not called")5�_Ð@BA)ÿÿÿÿ)0vMì±õ(*5 0exports['test number list'] = function(assert) { test(assert, [ 1, 2, 3 ])}/exports['test mixed list'] = function(assert) {P test(assert, [ 'a', 2, 'b', 4, {}, function() {}, /foo/, new Error('Boom!') ])}5�_ÐACB&5ÿÿÿÿ))vMì±õ&(. õ&(-5�_ÐBDC'ÿÿÿÿ**vMì±0õ&(. assert.deepEqual()5�_ÐCED'ÿÿÿÿ**vMì±4õ&(. tes5�_ÐDFE'ÿÿÿÿ**vMì±5õ&(. tes5�_ÐEGF'ÿÿÿÿ**vMì±8õ&(. test()5�_ÐFMG'ÿÿÿÿ**vMì±?õ&(. test(assert, [])5�_ÐGNHM'ÿÿÿÿ**vMì±Yõ&(. test(assert, [1, 2, 3, 4])5�_ÐMON'ÿÿÿÿ**vMì±[õ&(. test(assert, [2, 2, 3, 4])5�_ÐNPO'ÿÿÿÿ**vMì±]õ&(. test(assert, [2, 4, 3, 4])5�_ÐOQP'ÿÿÿÿ**vMì±_ õ&(. test(assert, [2, 4, 6, 4])5�_ÐPRQ'ÿÿÿÿ**vMì±q õ&(. test(assert, [2, 4, 6, 8])5�_ÐQSR ÿÿÿÿ**vMì±| õ .!function test(assert, expected) {5�_ÐRTS ÿÿÿÿ**vM챇õ $ var actual = [], isStopped = false5�_ÐSUT ÿÿÿÿ))vM챈õ 5�_ÐTVU ÿÿÿÿ((vM챉õ ,5 list.apply(null, expected)(function next(element) {5�_ÐUWV ÿÿÿÿ((vMì±�õ ,7 actual.apply(null, expected)(function next(element) {5�_ÐVXW ÿÿÿÿ((vM챕õ - õ ,5�_ÐWYX ÿÿÿÿ))vM챚õ - var elements5�_ÐX\Y ÿÿÿÿ))vMì±�õ- actual.push(element)5�_ÐY]Z\ÿÿÿÿ))vMì±Ïõ isStopped = true5�_Ð\^] ÿÿÿÿ((vMì±Øõ,5�_Ð]_^ÿÿÿÿ))vMì±Úõ+ assert.ok(isStopped, "stream is stopped")5�_Ð^`_ÿÿÿÿOvOMì±Þõ,P assert.deepEqual(actual, expected, "all elements were yielded in right order")5�_Ð_a`ÿÿÿÿOvOMì±ßõ 5�_Ð`ba ÿÿÿÿOvOMì±ãõ +)function test(assert, actual, expected) {5�_ÐacbÿÿÿÿOvOMì±æõ+5�_ÐbdcÿÿÿÿOvOMì±öõ+R assert.deepEqual(actual, expected, "all elements were yielded in right order")5�_Ðced "ÿÿÿÿOvOMì±úõ +/function test(assert, done, actual, expected) {5�_Ðdfe ÿÿÿÿOvOMì±ýõ + var elements = []5�_ÐegfÿÿÿÿOvOMì²õ +! actual(function next(element) {5�_Ðfhg ÿÿÿÿOvOMì²õ+ element.push(element)5�_ÐgihÿÿÿÿOvOMì²õ+T assert.deepEqual(elements, expected, "all elements were yielded in right order")5�_Ðhji'ÿÿÿÿOvOMì² õ+R assert.deepEqual(actual, expected, "all elements were yielded in right order")5�_Ðikj3ÿÿÿÿOvOMì²õ,@ "all elements were yielded in right order")5�_Ðjlk@ÿÿÿÿOvOMì²õ,H "all elements were yielded in correct right order")5�_Ðkml ÿÿÿÿ##vMì²-õ ",5�_Ðlnm"(ÿÿÿÿ$$vMì²1õ!#-+exports['test simple'] = function(assert) {5�_Ðmon&ÿÿÿÿ$$vMì²5õ%'-% test(assert, doubled, [2, 4, 6, 8])5�_Ðnqoÿÿÿÿ$$vMì²Uõ. õ-5�_Ðorpqÿÿÿÿ%%vMì²±õ/ õ.5�_Ðqsrÿÿÿÿ&&vMì²´õ/ console.log()5�_Ðrtsÿÿÿÿ&&vMì²µõ/ console.log('')5�_ÐsutÿÿÿÿvMì³aõ!0 õ!/5�_Ðtvu ÿÿÿÿvMì³bõ!0 test()5�_Ðuwv ÿÿÿÿvMì³dõ!0 test(map)5�_ÐvxwÿÿÿÿvMì³gõ0' map(empty, function onEach(element) {5�_Ðwyx ÿÿÿÿvMì³nõ!0 test()5�_Ðxzy ÿÿÿÿvMì³wõ!0 test(assert, done, mapped, )5�_Ðy{z!ÿÿÿÿvMì³xõ !+ assert.ok(isStopped, "stream is stopped")5�_Ðz|{!ÿÿÿÿvMì³yõ !E assert.ok(!isNexted, "map function was not called on empty stream")5�_Ð{}|+ÿÿÿÿvM쳃õ..exports['test map empty'] = function(assert) {5�_Ð|~}ÿÿÿÿvMì³£õ console.log('>>>>>>')5�_Ð}~ÿÿÿÿvMì³¼õ- }, function onStop(error) { isStopped = trueH assert.equal(error, undefined, 'stream is stopped without an error') })5�_Ð~€ÿÿÿÿvMì³½õ* }, )5�_Ð�€ÿÿÿÿvMì³Ðõ!+ õ!*5�_Ѐ‚� ÿÿÿÿvMì³Óõ!+ console.log()5�_Ð�ƒ‚ ÿÿÿÿvMì³Õõ!+ console.log('')5�_Ђ„ƒÿÿÿÿvMì³à õ +1exports['test simple'] = function(assert, done) {5�_Ѓ…„ ÿÿÿÿvMì³ê!õ  console.log('<<<<<')5�_Є†…%ÿÿÿÿvMì³ôõ%'+õ%'*5�_Ð…‡†& ÿÿÿÿvMì³÷"õ%'+ console.log()5�_Ð†Ž‡&ÿÿÿÿvMì´(õ%&console.log(exports)5�_Ї�‰ŽÿÿÿÿvMì´G)õ+ õ*5�_ÐŽ��&ÿÿÿÿvMì´hõ&(,õ&(+5�_Ð�‘�'ÿÿÿÿvMì´lõ&(, exports[]5�_Ð�’‘' ÿÿÿÿvMì´lõ&(, exports['']5�_Б“’'ÿÿÿÿvMì´põ&(,exports['test async map']5�_Ð’”“'%ÿÿÿÿvMì´sõ&(,&exports['test async map'] = function()5�_Г•”'2ÿÿÿÿvMì´võ&(,2exports['test async map'] = function(assert, done)5�_Д–•'4ÿÿÿÿvMì´võ&),5exports['test async map'] = function(assert, done) {}5�_Е—–'ÿÿÿÿvMì´wõ'). õ')-5�_Ж˜—!ÿÿÿÿvMì´{õ ! var isStopped = false5�_З™˜'ÿÿÿÿvMì´€õ&(- var is5�_Иš™'ÿÿÿÿvMì´†õ&(- function stream()5�_Й›š'ÿÿÿÿvMì´‡õ&)- function stream() {}5�_Кœ›'ÿÿÿÿvMì´ˆõ')/ õ').5�_Л�œ(ÿÿÿÿvMì´£õ')/ setTimeout()5�_Мž�(#ÿÿÿÿvMì´ªõ')/$ setTimeout(function onTimeout())5�_Ð�Ÿž(%ÿÿÿÿvMì´«*õ'*/' setTimeout(function onTimeout() {})5�_О Ÿ)ÿÿÿÿvMì´·õ(*0 })5�_П¡ (ÿÿÿÿvMì´¹õ(*1 õ(*05�_Р¢¡' ÿÿÿÿvMì´¼õ')2 õ')15�_С£¢* ÿÿÿÿvMì´Êõ)+2 if ()5�_Т¤£*ÿÿÿÿvMì´Ìõ)+2 if (x--)5�_У¥¤'ÿÿÿÿvMì´Øõ&(2 function stream() {5�_Ф¦¥)ÿÿÿÿvMì´Ýõ)+3 õ)+25�_Ð¥§¦*ÿÿÿÿvMì´àõ)+3 stop()5�_Ц¨§+ ÿÿÿÿvMì´æõ*,3 if (x--) next()5�_Ч©¨+ ÿÿÿÿvMì´éõ*,3 if () next()5�_Шª©*ÿÿÿÿvMì´îõ)+3 if (!x) stop()5�_Щ«ª+ ÿÿÿÿvMì´øõ*,3 next()5�_Ъ¬«+ ÿÿÿÿvMì´ü+õ*,3 next(x)5�_Ы­¬(ÿÿÿÿvMìµ ,õ')3 x = 55�_Ь®­( ÿÿÿÿvMìµõ(*4 õ(*35�_Э¯®)ÿÿÿÿvMìµ-õ() setTimeout5�_Ю°¯-ÿÿÿÿvMìµ õ-/4 õ-/35�_Я±°.ÿÿÿÿvMìµ"õ-/4 test()5�_а²±-ÿÿÿÿvMìµ0õ-/5 õ-/45�_б³².ÿÿÿÿvMìµ;õ-/5 var mapped = map()5�_в´³.ÿÿÿÿvMìµAõ-/5 var mapped = map(stream, )5�_гµ´.%ÿÿÿÿvMìµDõ-/5& var mapped = map(stream, function())5�_д¶µ.'ÿÿÿÿvMìµEõ-05) var mapped = map(stream, function() {})5�_е·¶.ÿÿÿÿvMìµHõ.07 õ.065�_ж¸·/ÿÿÿÿvMìµLõ-/7' var mapped = map(stream, function() {return õ.07 return 5�_з¹¸.$ÿÿÿÿvMìµNõ-/6/ var mapped = map(stream, function() { return 5�_иº¹.0ÿÿÿÿvMìµPõ-/60 var mapped = map(stream, function(x) { return 5�_й»º/ÿÿÿÿvMìµSõ-/65 var mapped = map(stream, function(x) { return x + 1})õ.06 })5�_к¼»/ÿÿÿÿvMìµWõ.05 test(assert, done, )5�_л½¼/ÿÿÿÿvMìµYõ.05 test(assert, done, mapped)5�_м¾½/ÿÿÿÿvMìµ[.õ.05 test(assert, done, mapped, [])5�_н¿¾+ÿÿÿÿvMìµ}õ+-6 õ+-55�_оÀ¿,ÿÿÿÿvMìµ�0õ+-6 setTimeout()5�_пÁÀ&ÿÿÿÿvM쵘õ%'64exports['test async map'] = function(assert, done) {5�_ÐÀÂÁ&ÿÿÿÿvM쵚õ%'68exports['test map async map'] = function(assert, done) {5�_ÐÁÃÂ& ÿÿÿÿvM최1õ%'6=exports['test map with async map'] = function(assert, done) {5�_ÐÂÄÃ1ÿÿÿÿvM쵤õ24exports0õ147õ1365�_ÐÃÅÄ3 ÿÿÿÿvMìµ§õ248 exports0''5�_ÐÄÆÅ3ÿÿÿÿvM쵨õ248 exports[]5�_ÐÅÇÆ3 ÿÿÿÿvM쵨õ248 exports['']5�_ÐÆÈÇ3ÿÿÿÿvMìµ¶õ248"exports['test map errored stream']5�_ÐÇÉÈ3!ÿÿÿÿvMìµ¼õ248!exports['test map broken stream']5�_ÐÈÊÉ3-ÿÿÿÿvM쵿õ248.exports['test map broken stream'] = function()5�_ÐÉËÊ3:ÿÿÿÿvMìµÂõ248:exports['test map broken stream'] = function(assert, done)5�_ÐÊÌË3<ÿÿÿÿvMìµÃõ258=exports['test map broken stream'] = function(assert, done) {}5�_ÐËÍÌ3ÿÿÿÿvMìµÄõ35: õ3595�_ÐÌÎÍ4ÿÿÿÿvMìµÊõ35: function stream()5�_ÐÍÏÎ4ÿÿÿÿvMìµÎõ35: function stream(next, stop)5�_ÐÎÐÏ4ÿÿÿÿvMìµÎõ36: function stream(next, stop) {}5�_ÐÏÑÐ4ÿÿÿÿvMìµÛõ46< õ46;5�_ÐÐÒÑ5ÿÿÿÿvMìµßõ46< 5�_ÐÑÓÒ5ÿÿÿÿvMìµåõ46< if ()5�_ÐÒÔÓ5 ÿÿÿÿvMìµæõ46< if (!x)5�_ÐÓÕÔ5ÿÿÿÿvMìµôõ46< if (!x) return stop()5�_ÐÔÖÕ5"ÿÿÿÿvMìµûõ46<$ if (!x) return stop(new Error())5�_ÐÕ×Ö5#ÿÿÿÿvMìµýõ46<& if (!x) return stop(new Error(""))5�_ÐÖØ×5ÿÿÿÿvMì¶õ57= õ57<5�_Ð×ÙØ6 ÿÿÿÿvMì¶ õ57= next()5�_ÐØÚÙ6 ÿÿÿÿvMì¶ õ68> õ68=5�_ÐÙÛÚ7ÿÿÿÿvMì¶õ68> 5�_ÐÚÜÛ7ÿÿÿÿvMì¶õ67 5�_ÐÛÝÜ6ÿÿÿÿvMì¶õ68> õ68=5�_ÐÜÞÝ4 ÿÿÿÿvMì¶%õ46? õ46>5�_ÐÝßÞ5 ÿÿÿÿvMì¶)õ57@ õ57?5�_ÐÞàß6ÿÿÿÿvMì¶0õ57@ setTimeout()5�_Ðßáà6$ÿÿÿÿvMì¶5õ57@$ setTimeout(function onTimeout())5�_Ðàâá6&ÿÿÿÿvMì¶6õ58@' setTimeout(function onTimeout()) {}5�_Ðáãâ7ÿÿÿÿvMì¶:õ68A }5�_Ðâäã8ÿÿÿÿ8:vMì¶>õ79A+ if (!x) return stop(new Error("Boom!")) next(x--) setTimeout()5�_Ðãåä8ÿÿÿÿ88vMì¶?õ78 5�_Ðäæå6ÿÿÿÿ88vMì¶@õ6:? õ68>5�_Ðåçæ8ÿÿÿÿ;;vMì¶Bõ79A next(x--)5�_Ðæèç9ÿÿÿÿ;;vMì¶Cõ8:A setTimeout()5�_Ðçéè6$ÿÿÿÿ;;vMì¶Gõ57A& setTimeout(function onTimeout()) {5�_Ðèêé9ÿÿÿÿ;;vMì¶Mõ8:A setTimeout()5�_Ðéëê:ÿÿÿÿ;;vMì¶S2õ9;A })5�_Ðêìë;ÿÿÿÿ;;vMì¶^õ;=B õ;=A5�_Ðëíì<ÿÿÿÿ;;vMì¶dõ;=B var mapped = map()5�_Ðìîí<$ÿÿÿÿ;;vMì¶jõ;=B& var mapped = map(stream, function())5�_Ðíïî<&ÿÿÿÿ;;vMì¶kõ;=B' var mapped = map(stream, function(x))5�_Ðîðï<(ÿÿÿÿ;;vMì¶nõ;=B* var mapped = map(stream, function(x) {})5�_Ðïñð<6ÿÿÿÿ;;vMì¶wõ<>C õ<>B5�_Ððòñ=ÿÿÿÿ;;vM춇õ<>C 5�_Ðñóò= ÿÿÿÿ;;vMì¶Šõ<>C mapped()5�_Ðòôó=ÿÿÿÿ;;vMì¶Žõ<>C mapped(function next())5�_Ðóõô=ÿÿÿÿ;;vMì¶Žõ<?C mapped(function next() {})5�_Ðôöõ=ÿÿÿÿ;;vMì¶›õ<>D mapped(function next() {5�_Ðõ÷ö<ÿÿÿÿ;;vMì¶ õ<>E õ<>D5�_Ðöø÷=ÿÿÿÿ;;vMì¶¢õ<= var 5�_Ð÷ùø<ÿÿÿÿ;;vMì¶£õ;=D8 var mapped = map(stream, function(x) { return x * x })5�_Ðøúù<ÿÿÿÿ;;vM춨õ<>E õ<>D5�_Ðùûú=ÿÿÿÿ;;vMì¶«õ<>E var elements = []5�_Ðúüû=ÿÿÿÿ;;vMì¶Ðõ<>E var elements = [ 9, 4, 1, 0 ]5�_Ðûýü= ÿÿÿÿ;;vMì¶Òõ=?F õ=?E5�_Ðüþý= ÿÿÿÿ;;vMì¶àõ<>F var actual = [ 9, 4, 1, 0 ]5�_Ðýÿþ>ÿÿÿÿ;;vMì¶ãõ=?F var expected = []5�_Ðþÿ?ÿÿÿÿ;;vMì¶èõ?AG õ?AF5�_Ðÿ@ÿÿÿÿ;;vMì¶êõ?AG actual.push()5�_Ð@ÿÿÿÿ;;vMì¶ëõ>@G mapped(function next(x) {actual.push(x)õ?AG actual.push(x)5�_Ð@ÿÿÿÿ;;vMì¶íõ>@F* mapped(function next(x) { actual.push(x)})õ?AF })5�_Ð?,ÿÿÿÿ;;vMì¶ïõ>@E- mapped(function next(x) { actual.push(x) })5�_Ð?=ÿÿÿÿ;;vMì¶ôõ>@E> mapped(function next(x) { actual.push(x) }, function stop())5�_Ð??ÿÿÿÿ;;vMì¶õõ>AEA mapped(function next(x) { actual.push(x) }, function stop() {})5�_Ð?<ÿÿÿÿ;;vMì¶øõ>@F? mapped(function next(x) { actual.push(x) }, function stop() {5�_Ð?@ÿÿÿÿ;;vMì¶úõ?AG õ?AF5�_Ð @ÿÿÿÿ;;vMì¶þõ?AG assert.equal()5�_Ð  @ÿÿÿÿ;;vMì·õ?AG assert.equal("")5�_Ð   @!ÿÿÿÿ;;vMì·õ?AG# assert.equal(error.message, "")5�_Ð   @'ÿÿÿÿ;;vMì·õ@BH õ@BG5�_Ð   Aÿÿÿÿ;;vMì·õ@BH assert.deepEqual()5�_Ð  @'ÿÿÿÿ;;vMì·&õ?AH( assert.equal(error.message, "Boom!")5�_Ð @*ÿÿÿÿ;;vMì·(õ?AH, assert.equal(error.message, "Boom!", "")5�_Ð@Bÿÿÿÿ;;vMì·7õ?AHQ assert.equal(error.message, "Boom!", "error propagated to the mapped stream")5�_ÐA(ÿÿÿÿ;;vMì·<3õ@BH* assert.deepEqual(actual, expected, "")5�_ÐAKÿÿÿÿ;;vMì·K6õACI õACH5�_Ð ÿÿÿÿ vMìð~õ Jõ I5�_Ð ÿÿÿÿvMìð‚õ Jvar test = require()5�_Ð ÿÿÿÿvMìð‚7õ Jvar test = require('')5�_Ð ÿÿÿÿ vMìðŽ8õ J/function test(assert, done, stream, expected) { var actual = []! stream(function next(element) { actual.push(element) }, function stop(error) {H assert.equal(error, undefined, "stream is stopped without an error")& assert.deepEqual(actual, expected,B "all elements were yielded in correct order") done() })}4exports['test map empty'] = function(assert, done) {5�_Ð ÿÿÿÿ vMìð�9õ =5�_Ð ÿÿÿÿ vMìð£:õ > var test = require('./utils.js')5�_Ð 'ÿÿÿÿ vMìðµ;õ >'var test = require('./utils.js').assert5�_Ðÿÿÿÿ $ vMìñ¼õ? õ>5�_Ð ÿÿÿÿ $ vMìñÂõ? assert.ok()5�_Ð ÿÿÿÿ $ vMìñÄõ? assert.ok(isNexted)5�_Ðÿÿÿÿ $ vMìñÆõ? assert.ok(!isNexted)5�_Ðÿÿÿÿ $ vMìñÆõ? assert.ok(!isNexted, "")5�_Ð ÿÿÿÿ $ vMìñÉ=õ? assert.ok(!isNexted, '')5�_Ð! ÿÿÿÿ $ vMìòÓõ? isNexted = true5�_Ð "!ÿÿÿÿ $ vMìòÚõ? assert.fail()5�_Ð!#"ÿÿÿÿ $ vMìòÜõ? assert.fail("")5�_Ð"$#ÿÿÿÿ $ vMìòÝ>õ? assert.fail('')5�_Ð#%$ÿÿÿÿ $ vMìòä?õ1 assert.ok(!isNexted, 'mapper was not exectued')5�_Ð$&%ÿÿÿÿ $ vMìò÷@õ >9 var empty = list(), isNexted = false, isStopped = false5�_Ð%'&ÿÿÿÿ&vÿÿÿMîVõ!? õ!>5�_Ð&(' ÿÿÿÿ&vÿÿÿMî[Aõ!? console.log()5�_Ð')( ÿÿÿÿ&vÿÿÿMîkBõ!? console.log(0)5�_Ð(*) ÿÿÿÿ&vÿÿÿMî†Cõ  console.log(x)5�_Ð)+*%/ÿÿÿÿ&vÿÿÿMî‹Dõ$&>2 test(assert, done, mapped, [ 6, 5, 4, 3, 2, 1 ])5�_Ð*,+2ÿÿÿÿ&vÿÿÿMî�Eõ13> var expected = [ 9, 4, 1, 0 ]5�_Ð+-,ÿÿÿÿ&vÿÿÿMî5‡õ>/*global define: true */5�_Ð,.-&ÿÿÿÿ&vÿÿÿMî5ŠFõ>(/*global define: true setTimeout: true*/5�_Ð-/. 'ÿÿÿÿ&vÿÿÿMî�±Gõ >Ovar streamer = require('../streamer'), map = streamer.map, list = streamer.list5�_Ð.0/ÿÿÿÿ&vÿÿÿMî‘õ ? "use strict";5�_Ð/10 ÿÿÿÿ&vÿÿÿMî‘Hõ ? 'use strict";5�_Ð021 #ÿÿÿÿ&vÿÿÿMî‘Iõ ?&var streamer = require('../streamer'),5�_Ð132-$ÿÿÿÿ&vÿÿÿMî‘)õ,.?- if (!x) return stop(new Error("Boom!"))5�_Ð243-*ÿÿÿÿ&vÿÿÿMî‘*õ,.?- if (!x) return stop(new Error('Boom!"))5�_Ð3546&ÿÿÿÿ&vÿÿÿMî‘-õ57?M assert.equal(error.message, "Boom!", "error propagated to mapped stream")5�_Ð4656 ÿÿÿÿ&vÿÿÿMî‘/õ57?M assert.equal(error.message, "Boom!', "error propagated to mapped stream")5�_Ð5766)ÿÿÿÿ&vÿÿÿMî‘0õ57?M assert.equal(error.message, 'Boom!', "error propagated to mapped stream")5�_Ð6876Kÿÿÿÿ&vÿÿÿMî‘3õ57?M assert.equal(error.message, 'Boom!', 'error propagated to mapped stream")5�_Ð7987Lÿÿÿÿ&vÿÿÿMî‘4õ68?N assert.deepEqual(actual, expected, "all values were yielded before error")5�_Ð8:97'ÿÿÿÿ&vÿÿÿMî‘7Jõ68?N assert.deepEqual(actual, expected, "all values were yielded before error')5�_Ð9;:= ÿÿÿÿ&vÿÿÿMî‘Dõ<>? require("test").run(exports);5�_Ð:<;=ÿÿÿÿ&vÿÿÿMî‘GKõ<>? require('test").run(exports);5�_Ð;=<:ÿÿÿÿN)¸õ;=exportsõ:=@õ:<?5�_Ð<>=<ÿÿÿÿN)»õ;=A exports[]5�_Ð=?>< ÿÿÿÿN)½õ;=A exports['']5�_Ð>@?<ÿÿÿÿN)Áõ;=Aexports['test partial read']5�_Ð?A@<ÿÿÿÿN)Äõ;=Aexports['test partial read'] 5�_Ð@BA<.ÿÿÿÿN)Éõ;=A.exports['test partial read of mapped stream'] 5�_ÐACB<9ÿÿÿÿN)Îõ;=A:exports['test partial read of mapped stream'] = function()5�_ÐBDC<FÿÿÿÿN)Ñõ;=AFexports['test partial read of mapped stream'] = function(assert, done)5�_ÐCED<HÿÿÿÿN)Òõ;>AIexports['test partial read of mapped stream'] = function(assert, done) {}5�_ÐDFE<ÿÿÿÿN)Ôõ<>C õ<>B5�_ÐEGF=ÿÿÿÿ*1vN)Ýõ<FC func5�_ÐFHGDÿÿÿÿ227v7N)æõDFL õDFK5�_ÐGIHCÿÿÿÿ34vN)ñõCGM õCEL5�_ÐHJIEÿÿÿÿ34vN)ôõDFO var actual = []5�_ÐIKJCÿÿÿÿ34vN)õõCEP õCEO5�_ÐJLKFÿÿÿÿ34vN* õFHQ õFHP5�_ÐKMLGÿÿÿÿ34vN*õFHQ var mapped = map()5�_ÐLNMG&ÿÿÿÿ34vN*õFHQ( var mapped = map(stream, function())5�_ÐMONG(ÿÿÿÿ34vN*õFHQ) var mapped = map(stream, function(x))5�_ÐNPOG*ÿÿÿÿ34vN*õFHQ, var mapped = map(stream, function(x) {})5�_ÐOQPG+ÿÿÿÿ34vN*õFHQ: var mapped = map(stream, function(x) { return x * x })5�_ÐPRQG4ÿÿÿÿ34vN*-õFHQD var mapped = map(stream, function(x) { called++; return x * x })5�_ÐQSRG+ÿÿÿÿ34vN*4õFHQF var mapped = map(stream, function(x) { called++ && return x * x })5�_ÐRTSGDÿÿÿÿ34vN*;õFHQM var mapped = map(stream, function(x) { return called++ && return x * x })5�_ÐSUT> ÿÿÿÿ34vN*_õ=?Q var x = 35�_ÐTVU?ÿÿÿÿ34vN*mõ>?% setTimeout(function onTimeout() {5�_ÐUWV?ÿÿÿÿ34vN*nõ>?- if (!x) return stop(new Error('Boom!'))5�_ÐVXW?ÿÿÿÿ34vN*nõ>? next(x--)5�_ÐWYX?ÿÿÿÿ34vN*nõ>? setTimeout(onTimeout, 0)5�_ÐXZY?ÿÿÿÿ34vN*oõ>? }, 0)5�_ÐY[Z> ÿÿÿÿ34vN*põ=?L var list5�_ÐZ\[>ÿÿÿÿ34vN*xõ=?L var stream = list()5�_Ð[]\>ÿÿÿÿ34vN*€õ=?L var stream = list(3, 2, 1)5�_Ð\^]=ÿÿÿÿ34vN*Šõ<= function stream(next, stop) {5�_Ð]_^=ÿÿÿÿ=AvN*Œõ<BK! var stream = list(3, 2, 1, 0) var called = 0 var expected = [ 9, 4, 1] var actual = []F var mapped = map(stream, function(x) { return called++ && x * x })5�_Ð^`_Cÿÿÿÿ=AvN*�õBC }5�_Ð_a`Cÿÿÿÿ=AvN*�õBC8 var mapped = map(stream, function(x) { return x * x })5�_Ð`baBÿÿÿÿ=AvN*‘õAB5�_ÐacbBÿÿÿÿ=AvN*‘õACH5�_Ðbdc<Eÿÿÿÿ=AvN*–Lõ;=HHexports['test partial read of mapped stream'] = function(assert, done) {5�_ÐcedBÿÿÿÿ=AvN*œõBD mappedõ@DHD var mapped = map(stream, function(x) { return called++ && x * x })õACH 5�_ÐdfeC ÿÿÿÿ=AvN*¦õBDI mapped()5�_ÐegfCÿÿÿÿ=AvN*©õBDI mapped(function ())5�_ÐfhgCÿÿÿÿ=AvN*¬õBDI mapped(function (element))5�_ÐgihCÿÿÿÿ=AvN*®õBEI mapped(function (element) {})5�_Ðhji>ÿÿÿÿ=AvN*±õ>@K õ>@J5�_ÐikjEÿÿÿÿ=BvN*¶õDFK })5�_ÐjlkEÿÿÿÿ=BvN*ºõDFK }, stopped)5�_ÐkmlEÿÿÿÿ=BvN*¾õDFK }, function stopped)5�_ÐlnmEÿÿÿÿ=BvN*ÀõDFK }, function stop())5�_ÐmonEÿÿÿÿ=BvN*ÁõDGK }, function stop() {})5�_ÐnpoDÿÿÿÿ=BvN*ÄõCEL mapped(function (element) {5�_ÐoqpDÿÿÿÿ=BvN*ÈõDFM õDFL5�_ÐprqEÿÿÿÿ=BvN*ÍõDFM actual.push()5�_Ðqsr?ÿÿÿÿ=BvN*Ïõ>? var stopped = 05�_Ðrts@ÿÿÿÿ=AvN*Ðõ@BM õ@BL5�_ÐsutAÿÿÿÿ=BvN*Ôõ@BM var stops = ]5�_ÐtvuEÿÿÿÿ=BvN*×õEGN õEGM5�_ÐuwvFÿÿÿÿ=BvN*ØõEGN if ()5�_ÐvywFÿÿÿÿ=BvN*âõEGN if (actual.length ==3)5�_ÐwzxyFÿÿÿÿ=BvN*ïõEGN if (actual.length !== )5�_Ðy{zFÿÿÿÿ=BvN*ñõEGN if (actual.length === )5�_Ðz|{Fÿÿÿÿ=BvN*òõEGN if (actual.length === 3)5�_Ð{}|Gÿÿÿÿ=BvN+õGIO õGIN5�_Ð|~}Gÿÿÿÿ=BvN+ õFHO }, function stop() {5�_Ð}~Hÿÿÿÿ=BvN+ õGIO stops.push()5�_Ð~€Iÿÿÿÿ=BvN+õJL assert.equalõILP õIKO5�_Ð�€Kÿÿÿÿ=BvN+ õJLQ assert.equal()5�_Ѐ‚�K!ÿÿÿÿ=BvN+(õJLQ# assert.equal(stops.length, 0, '')5�_Ð�ƒ‚KJÿÿÿÿ=BvN+<õKMR õKMQ5�_Ђ„ƒLÿÿÿÿ=BvN+GõKMR assert.equal()5�_Ѓ…„Lÿÿÿÿ=BvN+LõKMR assert.deepEqual())5�_Є†…Kÿÿÿÿ=BvN+NõKMS õKMR5�_Ð…‡†Lÿÿÿÿ=BvN+UõKMS assert.called()5�_Іˆ‡Fÿÿÿÿ=BvN+]õEGS) if (actual.length === 3) return false5�_Ї‰ˆLÿÿÿÿ=BvN+æõKMS assert.called(3)5�_ÐˆŠ‰Lÿÿÿÿ=BvN,õKMS assert.called(called, 3)5�_Љ‹ŠLÿÿÿÿ=BvN,õKMS assert.called(called, 3, '')5�_ЊŒ‹Lÿÿÿÿ=BvN, õKMS5 assert.called(called, 3, 'map function is called ')5�_Ћ�ŒLÿÿÿÿ=BvN,õKMS4 assert.called(called, , 'map function is called ')5�_ÐŒŽ�LAÿÿÿÿ=BvN,!õKMSC assert.called(called, expected.length, 'map function is called ')5�_Ð��ŽL7ÿÿÿÿ=BvN,/õKMSQ assert.called(called, expected.length, 'map function is called expected times')5�_ÐŽ��Mÿÿÿÿ=BvN,4õLNS assert.deepEqual(actual, ))5�_Ð�‘�Mÿÿÿÿ=BvN,6õLNS assert.deepEqual(actual, [])5�_Ð�’‘M&ÿÿÿÿ=BvN,FMõLNS( assert.deepEqual(actual, expected, '')5�_Б“’Lÿÿÿÿ=BvN,bNõKMSH assert.called(called, expected.length, 'map is called expected times')5�_Ð’”“Eÿÿÿÿ=BvN,xOõDFS actual.push(next)5�_Г•”Fÿÿÿÿ=BvN,‡PõEGS) if (actual.length !== 3) return false5�_Д–•B0ÿÿÿÿ=BvN,§õACSD var mapped = map(stream, function(x) { return called++ && x * x })5�_Е—–B1ÿÿÿÿ=BvN,¨õACS= var mapped = map(stream, function(x) { called++ && x * x })5�_Ж˜—B5ÿÿÿÿ=BvN,ªRõACS> var mapped = map(stream, function(x) { called++; && x * x })5�_З™˜<ÿÿÿÿ<OvN,Ýõ;=SBexports['test partial read of mapped stream'] = function(assert) {5�_Иš™<%ÿÿÿÿ< <$v$N,úõ;=S