VimŸUnDoåÄÉÎŒÕÒ=«÷8¾áÛÞO]6ÂÒèÿô§¡²ËcžTB)var streamer = require('../streamer.js'), #{{{{N_Z3_Ð 'ÿÿÿÿMìó¿õ IOvar streamer = require('../streamer'), map = streamer.map, list = streamer.list5�_Ð ÿÿÿÿMìóÁõ J, map = streamer.map, list = streamer.list5�_Ð ÿÿÿÿMìóÄõ J/ reduce = streamer.map, list = streamer.list5�_Ð ÿÿÿÿ  vMìóÒõ /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() })}5�_Ð ÿÿÿÿ  vMìóÔõ ? õ >5�_Ð ÿÿÿÿvMìóÚõ ?var test = require()5�_Ð ÿÿÿÿvMìóÚõ ?var test = require('')5�_Ð  ÿÿÿÿvMìóßõ ?var test = require('./assert')5�_Ð ÿÿÿÿvMìóáõ ?var test = require('./utils')5�_Ð ÿÿÿÿvMìóåõ?9 var empty = list(), isNexted = false, isStopped = false5�_Ð ÿÿÿÿvMìóùõ?4 var mapped = map(empty, function onEach(element) {5�_Ð ÿÿÿÿvMìóüõ? isNexted = true5�_Ð  ÿÿÿÿvMìôõ? assert.fail()5�_Ð ÿÿÿÿvMìôõ? assert.fail("")5�_Ð ÿÿÿÿvMìôõ? test(assert, done, mapped, [])5�_Ð ÿÿÿÿvMìôõ?7 var mapped = reduce(empty, function onEach(element) {5�_ÐÿÿÿÿvMìôõ? })5�_ÐÿÿÿÿvMìôõ? 5�_ÐÿÿÿÿvMìôõ? assert.equal()5�_ÐÿÿÿÿvMìô!õ? assert.equal(value, null)5�_ÐÿÿÿÿvMìô(õ? assert.equal(value, null, "")5�_Ð ÿÿÿÿvMìô0õ?5exports['test number map'] = function(assert, done) {5�_Ð ÿÿÿÿvMìô2õ?@exports['test map with async stream'] = function(assert, done) {5�_ÐÿÿÿÿvMìô6 õ ?4exports['test map empty'] = function(assert, done) {5�_Ð) ÿÿÿÿvMìô= õ(*?=(ÿÿÿÿBvBMìùfõ')C return x + 15�_Ð=?>*ÿÿÿÿBvBMìùoõ)+C2 test(assert, done, mapped, [ 6, 5, 4, 3, 2, 1 ])5�_Ð>@?*ÿÿÿÿ**%v%Mìùxõ)+C/ test(assert, done, sum, [ 6, 5, 4, 3, 2, 1 ])5�_Ð?A@*!ÿÿÿÿ**%v%Mìù|õ)+C, test(assert, done, sum, [ 5, 4, 3, 2, 1 ])5�_Ð@BAÿÿÿÿ**%v%Mìù‹õC@exports['test map with async stream'] = function(assert, done) {5�_ÐACBÿÿÿÿ**%v%Mìù�õCCexports['test reduce with async stream'] = function(assert, done) {5�_ÐBDC)ÿÿÿÿ**%v%Mìù�õ(*C })5�_ÐCED)ÿÿÿÿ**%v%Mìù õ(*C }, 0)5�_ÐDFE*ÿÿÿÿ**%v%Mìù¦õ)+C! test(assert, done, sum, [ 15 ])5�_ÐEGF- ÿÿÿÿ**%v%Mìù²õ,.C=exports['-test map broken stream'] = function(assert, done) {5�_ÐFHG6 ÿÿÿÿ**%v%Mìùºõ57C8 var mapped = map(stream, function(x) { return x * x })5�_ÐGIH6"ÿÿÿÿ**%v%MìùÀõ57C5 var sum = map(stream, function(x) { return x * x })5�_ÐHJI6%ÿÿÿÿ**%v%MìùÅõ57C8 var sum = map(stream, function(x, f) { return x * x })5�_ÐIKJ6%ÿÿÿÿ**%v%MìùÇõ57C8 var sum = map(stream, function(x, f) { return x * x })5�_ÐJLK65ÿÿÿÿ**%v%MìùÌõ57C8 var sum = map(stream, function(x, y) { return x * x })5�_ÐKML68ÿÿÿÿ**%v%MìùÕõ57C8 var sum = map(stream, function(x, y) { return x + y })5�_ÐLNM6ÿÿÿÿ**%v%MìùØõ57C8 var sum = map(stream, function(x, y) { return x + y })5�_ÐMON7ÿÿÿÿ**%v%MìùÜõ67 var expected = [ 9, 4, 1, 0 ]5�_ÐNPO7ÿÿÿÿ**%v%MìùÝõ67 var actual = []5�_ÐOQP7ÿÿÿÿ**%v%Mìùãõ68AD mapped(function next(x) { actual.push(x) }, function stop(error) {5�_ÐPRQ7'ÿÿÿÿ**%v%Mìùõõ68AA sum(function next(x) { actual.push(x) }, function stop(error) {5�_ÐQSR7ÿÿÿÿ**%v%Mìùûõ69A@ sum(function next(x) { assert.fail() }, function stop(error) {5�_ÐRTS8ÿÿÿÿ**%v%Mìùýõ7:B+ assert.fail() }, function stop(error) {5�_ÐSUT8ÿÿÿÿ**%v%Mìúõ79C assert.fail() 5�_ÐTVU8ÿÿÿÿ**%v%Mìúõ79C assert.fail("") 5�_ÐUWV8;ÿÿÿÿ**%v%Mìú õ79C; assert.fail("should not yield value if stream failed") 5�_ÐVXW;ÿÿÿÿ**%v%Mìú!õ:;N assert.deepEqual(actual, expected, "all values were yielded before error")5�_ÐWYX-ÿÿÿÿ**%v%Mìú"õ,.B2õ79B; assert.fail('should not yield value if stream failed');5�_Ðz{ #ÿÿÿÿN_Z3õ B)var streamer = require('../streamer.js'),5�_Ð "!ÿÿÿÿvMìö¢õ? test)5�çª