VimUnDo6j15鼬1ŕ+Ց,eПyp(I)var streamer = require('../streamer.js'), #N_Y5_ *M2 >Ovar streamer = require('../streamer'), map = streamer.map, list = streamer.list5_ :M2 >Pvar streamer = require('../streamer'), head = streamer.map, list = streamer.list5_ 'M2 >Qvar streamer = require('../streamer'), head = streamer.head, list = streamer.list5_M3 ?4exports['test map empty'] = function(assert, done) {5_ M3 ?4 var mapped = map(empty, function onEach(element) {5_M3?3 var silce = map(empty, function onEach(element) {5_M3?4 var silce = head(empty, function onEach(element) {5_ M3 , function onEach(element) {5_ M3& assert.fail('mapper was executed')5_ M3 })5_  M3=5exports['test number map'] = function(assert, done) {5_  M3 =@exports['test map with async stream'] = function(assert, done) {5_  ' M3#&(= =5_vM3h> var slice = head(empty)5_vM3i var slice = 5_vM3k= test(assert, done, slice, [])5_vM3m= test5_vM3n= test()5_ vM3q= test(assert)5_vM3r test(assert, d)5_vM3<5_vM35_ vM3<6exports['-test number map'] = function(assert, done) {5_vM3<5exports['test number map'] = function(assert, done) {5_vM3<3exports['test head map'] = function(assert, done) {5_ vM3<+ test(assert, done, doubled, [2, 4, 6, 8])5_! vM3<* test(assert, done, head(), [2, 4, 6, 8])5_ "!/vM3<1 test(assert, done, head(numbers), [2, 4, 6, 8])5_!#"vM3N var doubled = map(numbers, function onElement(number) { return number * 2 })5_"%#vM3exports<;5_#&$%vM4= exports[]5_%'&vM4 =7exports['test head default'] = function(assert, done) {5_&(' vM4= exports['']5_')(#vM4=#exports['test head smaller stream']5_(*)/vM4=0exports['test head smaller stream'] = function()5_)+*;vM4=;exports['test head smaller stream'] = function(async, done)5_*,+=vM4=>exports['test head smaller stream'] = function(async, done) {}5_+-,vM4? >5_,.-vM4!? var numbers = list()5_-/.vM4$@ ?5_.0/vM4'@ test()5_/10vM4-@ test(assert, done, head())5_021%vM40@& test(assert, done, head(numbers, 5))5_132(vM42@* test(assert, done, head(numbers, 5), [])5_2435vM4> @=exports['test head smaller stream'] = function(async, done) {5_354 vM4G@Aexports['-test map with async stream'] = function(assert, done) {5_465vM4I @@exports['test map with async stream'] = function(assert, done) {5_576&vM4W%&8 var mapped = map(stream, function(x) { return x + 1 })5_687&vM4Z%'?/ test(assert, done, mapped, [ 6, 5, 4, 3, 2 ])5_798&vM4\%'?/ test(assert, done, head(), [ 6, 5, 4, 3, 2 ])5_8:9&5vM4d%'?8 test(assert, done, head(stream, 3), [ 6, 5, 4, 3, 2 ])5_9;:&+vM4f %'?5 test(assert, done, head(stream, 3), [ 6, 5, 4, 3 ])5_:<;&/vM4t %'?2 test(assert, done, head(stream, 3), [ 5, 4, 3 ])5_;=<&2vM4{%'?5 test(assert, done, head(stream, 3), [ 5, 4, 3, 2 ])5_<>=) vM4(*?=exports['-test map broken stream'] = function(assert, done) {5_=D>)vM4(*?E@D;):vM4;N@;=?5_DFEM):vM4MOQ5_EGF)):vM4(*R@exports['test head of broken stream'] = function(assert, done) {5_FHG)3):vM4(*RPexports['test head befor stream error broken stream'] = function(assert, done) {5_GIH)):vM4(*RBexports['test head befor stream error'] = function(assert, done) {5_HJI< ):vM4;=R@exports['test head of broken stream'] = function(assert, done) {5_IKJ28):vM413R8 var mapped = map(stream, function(x) { return x * x })5_JLK2):vM413R test()5_KML2):vM413R test(assert, done, head())5_LNM2$):vM413R% test(assert, done, head(stream, 2))5_MON2'):vM413R) test(assert, done, head(stream, 2), [])5_NPO2"):vM413R0 test(assert, done, head(stream, 2), [3, 2, 1])5_OQP3):vM423 var expected = [ 9, 4, 1]5_PRQ3)9vM423 var actual = []5_QSR3)8vM423D mapped(function next(x) { actual.push(x) }, function stop(error) {5_RTS3)7vM423M assert.equal(error.message, "Boom!", "error propagated to mapped stream")5_SUT3)6vM423N assert.deepEqual(actual, expected, "all values were yielded before error")5_TVU3)5vM423 done()5_UWV3)4vM423 })5_VXW5 )3vM546KAexports['-test head of broken stream'] = function(assert, done) {5_WYX5)3vM5 46K@exports['test head of broken stream'] = function(assert, done) {5_XZY>)3vM5=>8 var mapped = map(stream, function(x) { return x * x })5_Y[Z>)3vM5=> var expected = [ 9, 4, 1]5_Z\[>)3vM5=> var actual = []5_[]\>)3vM5=?HD mapped(function next(x) { actual.push(x) }, function stop(error) {5_\^]>)3vM5=?HD head()(function next(x) { actual.push(x) }, function stop(error) {5_]_^50)3vM5$57I 57H5_^`_6 )3vM5)57I var actual = []5__a`6 )3vM5,57I var buffers = []5_`ba?+)3vM51>@IM head(stream, 5)(function next(x) { actual.push(x) }, function stop(error) {5_acbA)3vM57@BIN assert.deepEqual(actual, expected, "all values were yielded before error")5_bdcA%)3vM5<@BIN assert.deepEqual(buffer, expected, "all values were yielded before error")5_cedA)3vM5@@BIH assert.deepEqual(buffer, [], "all values were yielded before error")5_dgeA%)3vM5E@BIP assert.deepEqual(buffer, [3, 2, 1], "all values were yielded before error")5_ehfg99 v M5eI/*global define: true */5_gih@ 99 v M?AIM assert.equal(error.message, "Boom!", "error propagated to mapped stream")5_hji@&99 v M?AIM assert.equal(error.message, 'Boom!", "error propagated to mapped stream")5_ikj@)99 v M?AIM assert.equal(error.message, 'Boom!', "error propagated to mapped stream")5_jlk@K99 v M?AIM assert.equal(error.message, 'Boom!', 'error propagated to mapped stream")5_kmlAM99 v M@BIO assert.deepEqual(buffer, [3, 2, 1], "all values were yielded before error")5_lnmA(99 v M@BIO assert.deepEqual(buffer, [3, 2, 1], "all values were yielded before error')5_monG99 v MFHI require("test").run(exports);5_npoG 99 v MFHI require("test').run(exports);5_oqp-*99 v M,.I- if (!x) return stop(new Error("Boom!"))5_prq-$99 v M,.I- if (!x) return stop(new Error("Boom!'))5_qsr:$99 v M9;I- if (!x) return stop(new Error("Boom!"))5_rts:*99 v M 9;I- if (!x) return stop(new Error('Boom!"))5_sut99 v M I "use strict";5_tvu 99 v M! I 'use strict";5_uxv #99 v M% I&var streamer = require('../streamer'),5_vywx2"N&13I0 test(assert, done, head(stream, 3), [3, 2, 1])5_xzy2.N(13I0 test(assert, done, head(stream, 2), [3, 2, 1])5_y{z2"NY13I- test(assert, done, head(stream, 2), [3, 2])5_z{2+N[/13I- test(assert, done, head(stream, 3), [3, 2])5_{|NOI(typeof define === "undefined" ? function ($) { $(require, exports, module) } : define)(function (require, exports, module, undefined) {5_INO0H})5_GNO4FHI require('test').run(exports);5_ #N_Y5 I)var streamer = require('../streamer.js'),5_{}|-*2vN-.I -/J console.log()5_|~}.*2vN-/J console.log(x)5_}~.*2vN+-/J console.log('>>>>>>>', x)5_~ *2vN-J@exports['-test head of async stream'] = function(assert, done) {5_.*1vNΩ.-/5_vxw) NJ$(*IDexports['-test head before stream error'] = function(assert, done) {5_egfA%)3vM5M@BIR assert.deepEqual(buffer, [3, 2, 1, 0], "all values were yielded before error")5_>A?D@1vM412? 13@ var slice = head()5_@BA2vM413@ var slice = head(stream, 2)5_ACB3vM4245_BC3vM4245_>@?2vM41313> var expected = [ 9, 4, 1]5_#%$vM3=0exports['test head '] = function(assert, done) {5_vM3<- test(assert, head(), doubled, [2, 4, 6, 8])5_vM3<4 test(assert, head(numbers), doubled, [2, 4, 6, 8])5