VimUnDoLz׳_)pxG[Uu˟vxr'p)var streamer = require('../streamer.js'), #N_Z-N_ M| A2 filter = streamer.filter, list = streamer.list5_ M A/ zip = streamer.filter, list = streamer.list5_M A7exports['test filter empty'] = function(assert, done) {5_M A4exports['test zip empty'] = function(assert, done) {5_MB A5_MB var numbers = list()5_M B7 var mapped = filter(empty, function onEach(element) {5_  M B4 var mapped = zip(empty, function onEach(element) {5_ M  zipfunction onEach(element) {B4 var zipped = zip(empty, function onEach(element) {5_ M T zip(function onEach(element) {5_ M U( assert.fail('filterer was executed')5_  M V })5_  M \A test(assert, done, mapped, [])5_ M `A8exports['test number filter'] = function(assert, done) {5_ M bACexports['test filter with async stream'] = function(assert, done) {5_+ M h*,A?exports['test filter broken stream'] = function(assert, done) {5_ M A9exports['-test number filter'] = function(assert, done) {5_M A8exports['test number filter'] = function(assert, done) {5_M B A5_M B var letters = list()5_M B var letters = list('')5_M B var letters = list('a')5_M B var letters = list('a', '')5_M B var letters = list('a', 'b')5_ M B" var letters = list('a', 'b', '')5_"M B# var letters = list('a', 'b', 'c')5_%M B' var letters = list('a', 'b', 'c', '')5_%M C B5_M  C var zipped = zip()5_ M : var evens = filter(numbers, function onElement(number) {5_! M  return !(number % 2)5_ "!M  })5_!#"M!@# test(assert, done, evens, [2, 4])5_"$#M!@$ test(assert, done, zipped, [2, 4])5_#%$M!A 2, 4])5_$&%M!B])5_%'&M! B 2, 45_&('M!3B []5_')( M!7B [ 1, '']5_(*) M!8B [ 1, 'a']5_)+*M!9 B [ 1, 'a' ]5_*,+M!;C []5_+-, M!>C [ 2, '']5_,.- M!?C [ 2, 'b']5_-/.M!@ C [ 2, 'b' ]5_.0/M!BD []5_/10 M!DD [ 3, '']5_021 M!ED [ 3, 'c']5_132M!F D [ 3, 'c' ]5_243M!KE []5_354 M!ME [ 4, '']5_465 M!N E [ 4, 'd']5_576M!RE [ 1, 'a' ], [ 2, 'b' ],E [ 2, 'b' ],5_687M!TD [ 1, 'a' ], [ 2, 'b' ], [ 3, 'c' ],D [ 3, 'c' ],5_798M!VC' [ 1, 'a' ], [ 2, 'b' ], [ 3, 'c' ], [ 4, 'd' ]C [ 4, 'd' ]5_8:9M!XB test(assert, done, zipped, [.[ 1, 'a' ], [ 2, 'b' ], [ 3, 'c' ], [ 4, 'd' ]B2 [ 1, 'a' ], [ 2, 'b' ], [ 3, 'c' ], [ 4, 'd' ]5_9;:M![AL test(assert, done, zipped, [[ 1, 'a' ], [ 2, 'b' ], [ 3, 'c' ], [ 4, 'd' ]])A ])5_:<;M!c @O test(assert, done, zipped, [[ 1, 'a' ], [ 2, 'b' ], [ 3, 'c' ], [ 4, 'd' ] ])5_;=< M!@Dexports['-test filter with async stream'] = function(assert, done) {5_<>=M!@Cexports['test filter with async stream'] = function(assert, done) {5_=?>M!@@exports['test zip with async stream'] = function(assert, done) {5_>@?M! @Eexports['test zip sync with async stream'] = function(assert, done) {5_?A@&/M!%(@C var odds = filter(stream, function(number) { return number % 2 })5_@BA&M!%'A. var odds = filter(stream, function(number) {5_ACB'M!&)A return number % 2 })5_BDC& M!%'B+ var odds = zip(stream, function(number) {5_CEDM"B function stream(next, stop) {5_DFE& M"%'B. var stream2 = zip(stream, function(number) {5_EGF& M" %(B( var b = zip(stream, function(number) {5_FHG& M" %'C var b = 5_GIH&M"%'C var b = list()5_HJI&M"%'C var b = list('')5_IKJ&M"%'C var b = list('a')5_JLK&M"%'C var b = list('a', '')5_KML&M"%'C var b = list('a', 'b')5_LNM&M"%'C var b = list('a', 'b', '')5_MON&M"%'C var b = list('a', 'b', 'c')5_NPO&M"%'C! var b = list('a', 'b', 'c', '')5_OQP&!M"%'C" var b = list('a', 'b', 'c', 'd')5_PRQ&$M"%'C& var b = list('a', 'b', 'c', 'd', '')5_QSR&$M" &(C5_RTS'M"$&(D5_SUT'M"3&(D var c = list()5_TVU'M"4&(D var c = list('')5_UWV'M"5&(D var c = list('~')5_VXW'M":&(D var c = list('~', '')5_WYX'M";&(D var c = list('~', '@')5_XZY'M"<&(D var c = list('~', '@', '')5_Y[Z'M"=&(D var c = list('~', '@', '!')5_Z\['M"@&(D! var c = list('~', '@', '!', '')5_[]\'!M"A&(D" var c = list('~', '@', '!', '#')5_\^]'$M"D&(D& var c = list('~', '@', '!', '#', '')5_]_^'$M"`')D5_^`_) M"f(+E zip(stream, function(number) {5__a`)M"l(*F zip(a, b, c)5_`ba*M"t)* , function(number) {5_acb*M"u)* return number % 25_bdc*M"u)* })5_ced)M"v)+C5_dfe+ M"x*,D' test(assert, done, odds, [ 5, 3, 1 ])5_egf+%M"*-D' test(zipped, done, odds, [ 5, 3, 1 ])5_fhg+M"+-F +-E5_gih,M"+-F []5_hji,M"+-F [ 5, ]5_ikj,M",. +.F [ 5, 4, 3, 2, 1, 0 ]5_jlk-M",.G []5_kml-M",.G [ '']5_lnm- M",.G [ 'a']5_mon- M",.G [ 'a', '']5_npo-M",.G [ 'a', 'b']5_oqp-M",.G [ 'a', 'b', '']5_prq-M",.G [ 'a', 'b', 'c']5_qsr-M",.G [ 'a', 'b', 'c', '']5_rts-M",.G [ 'a', 'b', 'c', 'd']5_sut-M",.G [ 'a', 'b', 'c', 'd', '']5_tvu-M",.G [ 'a', 'b', 'c', 'd', 'e']5_uwv,M"+-G [ 5, 4, 3, 2, 1, 0 ],5_vxw-M"-/ ,/G [ 'a', 'b', 'c', 'd', 'e' ]5_wyx.M"-/H []5_xzy.M"-/H [ '']5_y{z. M"-/H [ '~']5_z|{. M"-/H [ '~', `@]5_{}|. M"-/H [ '~', '']5_|~}.M"-/H [ '~', '@']5_}~.M"-/H [ '~', '@', '']5_~.M"-/H [ '~', '@', '!']5_.M"-/H [ '~', '@', '!', '']5_.M"-/H [ '~', '@', '!', '#']5_.M"-/H [ '~', '@', '!', '#', '']5_.M"-/H [ '~', '@', '!', '#', '^']5_-M",.H [ 'a', 'b', 'c', 'd', 'e' ],5_,M"+-H [ 5, 4, 3, 2, 1 ],5_+ M#*,H test(zipped, done, odds, [5_+M#*,H test(assert, done, odds, [5_, M#)+-H [ 5, 4, 3, 2 ],5_, M#*+-H [ 5, '', 3, 2 ],5_,M#,+-H [ 5, 'a', 3, 2 ],5_,M#3+-H [ 5, 'a', '', 2 ],5_,M#4+-H [ 5, 'a', '~', 2 ],5_- M#<,.H [ 'a', 'b', 'c', 'd' ],5_-M#B,.H [ 4, 'b', 'c', 'd' ],5_-M#D,.H [ 4, 'b', '@', 'd' ],5_-M#G-/I -/H5_.M#H-/I []5_. M#L-/I [ 3, '']5_. M#M-/I [ 3, 'c']5_.M#N-/I [ 3, 'c', '']5_.M#O-/I [ 3, 'c', '!']5_.M#P.0 -0I [ 3, 'c', '!' ]5_/M#R.0J []5_/ M#U.0J [ 2, '']5_/ M#W.0J [ 2, '#']5_/M#].0J [ 2, 'd', '']5_/M#^.0J [ 2, 'd', '#']5_0M#`/0 [ '~', '@', '!', '#' ]5_'%M#x&(I' var c = list('~', '@', '!', '#', '^')5_3 M#24I@exports['~test filter broken stream'] = function(assert, done) {5_3M#24I?exports['test filter broken stream'] = function(assert, done) {5_3M#24IH <>G5_= M$<>H zipped()5_=M$<>H zipped = 5_=M$<>H var zipped = 5_=M$<>H var zipped = zip()5_=M$)<>H var zipped = zip(stream)5_=M$->@ test=@I =?H5_?M$3>@J test()5_?M$?>AJ test(assert, done, zipped, [])5_<'M$T;=K( var numbers = list('a', 'b', 'c', 'd')5_3"M$b24K?exports['test zip on broken stream'] = function(assert, done) {5_3M$j24K?exports['test zip on broken stream'] = function(assert, done) {5_@M${?AK])5_AAEvM$@BKF filtered(function next(x) { actual.push(x) }, function stop(error) {O assert.equal(error.message, "Boom!", "error propagated to filtered stream")N assert.deepEqual(actual, expected, "all values were yielded before error") done() })5_AAAvM$@A 5_?AAvM$?AG ?AF5_@BBvM$?AG []5_@BBvM$?AG [ '']5_@ BBvM$?AG [ 3, '']5_@ BBvM$?AG [ 3, 'a']5_@BBvM$@B ?BG [ 3, 'a' ]5_ACCvM$@BH []5_A CCvM$@BH [ 2, '']5_A CCvM$@BH [ 2, 'b']5_ACCvM$AC @CH [ 2, 'b' ]5_BDDvM$ACI []5_B DDvM$ACI [ 1, '']5_B DDvM$ACI [ 1, 'c']5_@ DDvM$?AI [ 3, 'a' ],5_@ DDvM$?AI [ 'a' ],5_@ DDvM$?AI [ 'a', '' ],5_A DDvM$@BI [ 2, 'b' ],5_A DDvM$@BI [ 'b' ],5_B DDvM$ACI [ 1, 'c' ]5_B DDvM$ ACI [ 'c' ]5_6 DDvM$68J 68I5_7EEvM$68J console.log()5_7EEvM$68J console.log('')5_7EEvM$$68J console.log('>>>>')5_7EEvM%&67 console.log('>>>>', x)5_E!v!M EGJEGI5_F!v!MEGJ exports[]5_F !v!MEGJ exports['']5_F$!v!MEGJ$exports['test zip with early error']5_F0!v!M!EGJ1exports['test zip with early error'] = function()5_F=!v!M$EGJ=exports['test zip with early error'] = function(assert, done)5_F?!v!M%EHJ@exports['test zip with early error'] = function(assert, done) {}5_F!v!M&FHL FHK5_G G G v M/FQL function 5_O"G G v M3NPU# var numbers = list('a', 'b', 'c')5_O%G G v M4'NPU' var numbers = list('a', 'b', 'c', '')5_P"G G v M5PRV PRU5_QG G v M=PRV zip5_QG G v M>PRV zip5_Q G G v MAPRV zipped()5_Q G G v MBPRV zipped({})5_QG G v MKPRV zipped(function onElement())5_Q"G G v MLPRV# zipped(function onElement(tuple))5_Q$G G v MMPSV& zipped(function onElement(tuple) {})5_QG G v MQPRW$ zipped(function onElement(tuple) {5_RG G v MUQSW })5_R G G v MYQSW }, onStop())5_RG G v MYQTW }, onStop() {})5_R G G v M[QSX }, onStop() {5_RG G v M_QSX }, onStop(error) {5_R G G v MaRTY RTX5_SG G v MeRTY assert.equal()5_S!G G v MjRTY# assert.equal(error.message, "")5_S'G G v MlRTY( assert.equal(error.message, "Boom!")5_S*G G v Mo(RTY, assert.equal(error.message, "Boom!", "")5_P"G G v M)PRZ PRY5_RG G v MRT[ RTZ5_SG G v M*RT[ buffer.push()5_UG G v MUW\ UW[5_VG G v MUW\ assert.deepEqual()5_VG G v MUX\ assert.deepEqual(buffer, [])5_VG G v MVX^ VX]5_WG G v MVX^ []5_PG G v MOQ^# var zipped = zip(numbers, stream)5_PG G v MOQ^ var zipped = zip(stream)5_O P!PvMNP^( var numbers = list('a', 'b', 'c', 'd')5_<< <vM;=^# var numbers = list('a', 'b', 'c')5_=< <vM<>^# var zipped = zip(numbers, stream)5_W< <vMVX^ [ ]5_W < <vMVX^ [ 3, '']5_W< <vMVX^ [ 3, 'a']5_W< <vMWY VY^ [ 3, 'a' ]5_X< <vMWY_ []5_ X < <vMWY_ [ 2, '']5_  X< <vMWY_ [ 2, 'b']5_   X< <vMXZ WZ_ [ 2, 'b' ]5_   Y< <vMXZ` []5_   Y < <vMXZ` [ 1, '']5_  Y< <vM,XZ` [ 1, 'c']5_ Z< <vM-Z\a Z\`5_Z< <vMY[a ])5_Z< <vM.Y[a ], '')5_ZA< <vMY[aQ ], 'Stream yielded all elements in right order before source stream errored')5_ZA< <vM/Y[aC ], 'Stream yielded all elements in right order before errored')5_Z< <vM*Y[aR ], 'Stream yielded all elements in right order before error in source stream')5_Z< <vM+Y[aN ], 'Stream yielded elements in right order before error in source stream')5_Z#< <vM-1Y[aR ], 'Stream yielded all elements in right order before error in source stream')5_UUGUvMDTVaH assert.equal(error.message, "Boom!", "Stream is stopped with error")5_UUGUvMDTU 5_YUGUvMF3Y[a Y[`5_IUGUvM\IKb IKa5_JVGVvM`4IKb console.log()5_JVGVvMh6IKb console.log(x)5_[VGVvM7Z\bH assert.equal(error.message, "Boom!", "Stream is stopped with error")5_ UVGVvMUWc UWb5_! VWGWvM8UWc console.log()5_ "!JXXvMIJ console.log('<<<<', x)5_!#"UWWvM9TU console.log(buffer)5_"$#F VVvM:EGa?exports['test zip with early error'] = function(assert, done) {5_#%$ #v#M;aLexports['test zip sync stream with async stream'] = function(assert, done) {5_$&%3 #v#M<24a>exports['test zip with late error'] = function(assert, done) {5_%'& #v#M=aMexports['-test zip sync stream with async stream'] = function(assert, done) {5_&('3 #v#M>24a?exports['-test zip with late error'] = function(assert, done) {5_')(F #v#M?EGa@exports['-test zip with early error'] = function(assert, done) {5_(*)Z#v#M@Y[aJ //assert.equal(error.message, "Boom!", "Stream is stopped with error")5_)+*7$#v#M68a- if (!x) return stop(new Error("Boom!"))5_*,+7*#v#M68a- if (!x) return stop(new Error('Boom!"))5_+-,J$#v#MIKa- if (!x) return stop(new Error("Boom!"))5_,.-J*#v#MIKa- if (!x) return stop(new Error('Boom!"))5_-/.Z #v#MY[aH assert.equal(error.message, "Boom!", "Stream is stopped with error")5_.0/Z&#v#MY[aH assert.equal(error.message, 'Boom!", "Stream is stopped with error")5_/10Z)#v#MY[aH assert.equal(error.message, 'Boom!', "Stream is stopped with error")5_021ZF#v#MY[aH assert.equal(error.message, 'Boom!', 'Stream is stopped with error")5_132_ #v#M^`a require("test").run(exports);5_243_#v#M^`a require('test").run(exports);5_354 #v#M a "use strict";5_465#v#M a "use strict';5_576#v#MA a .use strict';5_687 ##v#MB a&var streamer = require('../streamer'),5_798#v#MC 5_8:9]F]v N0D^xc]`b]_a5_9;:lF]v N0ln| ln{5_:<;mF]v N0ln| if ()5_;=<mF]v N0ln| if (buffer.length === 2)5_<>=`F]v N0_` function stream(next, stop) {5_=?>`F]v N0_` var x = 35_>@?`F]v N0_`% setTimeout(function onTimeout() {5_?A@`F]v N0_`- if (!x) return stop(new Error('Boom!'))5_@BA`F]v N0_` next(x--)5_ACB`F]v N0_` setTimeout(onTimeout, 0)5_BDC`F]v N0_` }, 0)5_CED`F]v N0_` }5_DFE`F]v N0`bu `bt5_EGFaF]v N0`bu var numbers = list()5_FHGbF]v N0acu# var zipped = zip(stream, letters)5_GIHfF]v N0egu) if (buffer.length === 2) return false5_HJIKF]v N1JLu next(x--)5_IKJKF]v N1 JLu if (false !== next(x--)5_JLKLF]v N1 EJLu if (false !== next(x--))setTimeout(onTimeout, 0)KMu setTimeout(onTimeout, 0)5_KML8F\v N179t next(x--)5_LNM8F\v N179t if (false !== next(x--)5_MON9F\v N1F79t if (false !== next(x--))setTimeout(onTimeout, 0)8:t setTimeout(onTimeout, 0)5_NPO"E[v N1!#s next(x--)5_OQP"E[v N1%!#s if (false !== next(x--)5_PRQ#E[v N1'G!#s if (false !== next(x--))setTimeout(onTimeout, 0)"$s setTimeout(onTimeout, 0)5_QSRdDZv N1dfs dfr5_RTSeDZv N1dfs stopped.push()5_SUTfDZv N1ef assert.deepEqual(buffer, [5_TVUfDZv N1ef [ 3, 'a' ],5_UWVfDZv N1ef [ 2, 'b' ],5_VXWfDZv N1ef [ 1, 'c' ]5_WYXfDZv N1efP ], 'Stream yielded all tuples in right order before error in source stream')5_XZYfDZv N1efH assert.equal(error.message, 'Boom!', 'Stream is stopped with error')5_Y[ZfDZv N1ef done()5_Z\[\<DZv N1[]l?exports['test zip with early error'] = function(assert, done) {5_[]\`DZv N1`bm `bl5_\^]gDZv N1gin gim5_]_^hDZv N1gin assert.equal()5_^`_h DZv N1gin" assert.equal(stopped.length, '')5__a`h#DZv N1gin% assert.equal(stopped.length, 0, '')5_`bah:DZv N1Hgin; assert.equal(stopped.length, 0, 'interrupted streams do')5_acbhBDZv N2hjo hjn5_bdciDZv N2!hjo assert.equal()5_cediDZv N2'hjo assert.deepEqual())5_dfeiDZv N2*hjo assert.deepEqual(buffer, []))5_egfiDZv N2+hjo" assert.deepEqual(buffer, [ '']))5_fhgiDZv N2,hjo" assert.deepEqual(buffer, [ []]))5_gihiDZv N2/hjo$ assert.deepEqual(buffer, [ ['']]))5_hjii"DZv N24hjo' assert.deepEqual(buffer, [ [1, '']]))5_ikji%DZv N26hjo( assert.deepEqual(buffer, [ [1, 'a']]))5_jlki(DZv N2:hjo, assert.deepEqual(buffer, [ [1, 'a'], []]))5_kmli*DZv N2:hjo/ assert.deepEqual(buffer, [ [1, 'a'], [ '']]))5_lnmi,DZv N2<hjo0 assert.deepEqual(buffer, [ [1, 'a'], [ 'b']]))5_moni)DZv N2>hjo0 assert.deepEqual(buffer, [ [1, 'a'], [ 'b']]))5_npoi/DZv N2Ahjo3 assert.deepEqual(buffer, [ [1, 'a'], [ 2, 'b']]))5_oqpi1DZv N2Chjo4 assert.deepEqual(buffer, [ [1, 'a'], [ 2, 'b' ]]))5_prqi4DZv N2Dhjo8 assert.deepEqual(buffer, [ [1, 'a'], [ 2, 'b' ], []]))5_qsri9DZv N2Ghjo> assert.deepEqual(buffer, [ [1, 'a'], [ 2, 'b' ], [ 3, '']]))5_rtsi;DZv N2Hhjo? assert.deepEqual(buffer, [ [1, 'a'], [ 2, 'b' ], [ 3, 'c']]))5_suti=DZv N2Ihjo@ assert.deepEqual(buffer, [ [1, 'a'], [ 2, 'b' ], [ 3, 'c' ]]))5_tvui@DZv N2NhjoD assert.deepEqual(buffer, [ [1, 'a'], [ 2, 'b' ], [ 3, 'c' ], []]))5_uwviEDZv N2QhjoJ assert.deepEqual(buffer, [ [1, 'a'], [ 2, 'b' ], [ 3, 'c' ], [ 3, '']]))5_vxwiGDZv N2RhjoK assert.deepEqual(buffer, [ [1, 'a'], [ 2, 'b' ], [ 3, 'c' ], [ 3, 'd']]))5_wyxiIDZv N2UhjoL assert.deepEqual(buffer, [ [1, 'a'], [ 2, 'b' ], [ 3, 'c' ], [ 3, 'd' ]]))5_xzyiMDZv N2XhjoM assert.deepEqual(buffer, [ [1, 'a'], [ 2, 'b' ], [ 3, 'c' ], [ 3, 'd' ] ]))5_y{ziKDZv N2Yik )hkoL assert.deepEqual(buffer, [ [1, 'a'], [ 2, 'b' ], [ 3, 'c' ], [ 3, 'd' ] ])5_z}{jDZv N2]Iikp '')5_{~|}jDZv N2oikp, 'stream was interrupted')5_}~j+DZv N2uJikp9 'stream yielded elements interrupted')5_~\DZv N2K[]p9exports['test zip with early error'] = function(assert) {5_NOp(typeof define === "undefined" ? function ($) { $(require, exports, module) } : define)(function (require, exports, module, undefined) {5_pNOo})5_nNOMmop require('test').run(exports);5_ #N_Z,N p)var streamer = require('../streamer.js'),5_{}|jDZv N2jikp) 'stream interrupted')5_ZHUGUvMLY[aQ assert.equal(error.message, "Boom!", "Stream is stopped with error")kkkkkkkkk5_Z< <vM$Y[aC ], 'all elements in right order before error in source stream')5_5 EEvM%Q"46J var x = 45_@M$@?AK ])5_   M XA test(zip, done, mapped, [])5