VimUnDo>Gk4gه$ Rt.42H)}))\\\\NOp_ MM Ovar streamer = require('../streamer'), map = streamer.map, list = streamer.list5_ MM 5_ MN G/function test(assert, done, stream, expected) {5_ MQ G7exports.function test(assert, done, stream, expected) {5_M\34exports['test map empty'] = function(assert, done) {9 var empty = list(), isNexted = false, isStopped = false4 var mapped = map(empty, function onEach(element) { isNexted = true }) test(assert, done, mapped, [])}5exports['test number map'] = function(assert, done) { var numbers = list(1, 2, 3, 4)N var doubled = map(numbers, function onElement(number) { return number * 2 })+ test(assert, done, doubled, [2, 4, 6, 8])}@exports['test map with async stream'] = function(assert, done) { function stream(next, stop) { var x = 5% setTimeout(function onTimeout() { if (!x) return stop() next(x--) setTimeout(onTimeout, 0) }, 0) }8 var mapped = map(stream, function(x) { return x + 1 })2 test(assert, done, mapped, [ 6, 5, 4, 3, 2, 1 ])}exports.test = function test(assert, done, stream, expected) {5_ BN" Eexports.test = function test(assert, done, stream, expected, error) {5_!N"H assert.equal(error, undefined, 'stream is stopped without an error')5_CN"E assert.equal(error, reason, 'stream is stopped without an error')5_ N" @ assert.equal(error, reason, 'stream is stopped as expected')5_N\5_N\ exports.function pipe(readers) {5_%N] exports.function pipe(readers) {5_&%N^pexports.read = function read5_%'&N^yexports.read = function read()5_&('$N^z$exports.read = function read(stream)5_')(&N^{'exports.read = function read(stream) {}5_(*)N^|  5_)+*N^!  5_*,+ N^! stream()5_+-,N^! stream(function())5_,.-N^! stream(function(next, stop))5_-/.N^ !! stream(function(next, stop) {})5_.0/#N^"&exports.read = function read(stream) {5_/10N^" stream(function(next, stop) {5_021N^" stream(buffer.push.bind()5_132!N^"! stream(buffer.push.bind(buffer)5_243N^ })5_354'N^!' stream(buffer.push.bind(buffer), done5_4651N^ "  !5_576)Na#",exports.read = function read(stream, done) {5_6871Na*"4exports.read = function read(stream, done, numebr) {5_798Na2" var buffer = []5_8:9!Na@ #2 stream(buffer.push.bind(buffer), done || Object)5_9;:NaF #+ stream(function onNext(), done || Object)5_:<;NaF!#. stream(function onNext() {}, done || Object)5_;=<NaN!$5_<>=NaQ % stream(function onNext() {5_=?> NaS!%5_>@? NaV!% if ()5_?A@ Na\!% if (buffer.)5_@BA Na_!% buffer.push()5_ACB Naa "&  "%5_BDC!Nac "& if ()5_CED!Nak "& if (buffer.length)5_DFE!Nam "& return if (buffer.length)5_EGF!Nao "& return buffer.length)5_FHG Nav "'  "&5_GIH!%Na "'% // Interrupt reading if length is5_HJI1Na'4exports.read = function read(stream, done, number) {5_IKJNa' number = number || Infinity5_JLKNa' length = number || Infinity5_KML"#Na!#'# return buffer.length !== number5_LNM!Na "'& // Interrupt reading if length is 5_MON!3Na "'3 // Interrupt reading if read desired length is 5_NPO!0Na "'0 // Interrupt reading if read desired length 5_OQPNa (  '5_PRQ$Na#%( }, done || Object)5_QSR$ Ne#%( }, done)5_RTS$Ne#%( }, function onStop())5_SUT$Ne#%( }, function onStop(reason))5_TVU$Ne#&( }, function onStop(reason) {})5_UWV$Ne!$&* $&)5_VXW%Ne#$&* if ()5_WYX% Ne%$&* if (done)5_XZY%Ne'$&* if (done) done()5_Y[ZNe, done = done || Object5_Z\[NOm)(typeof define === "undefined" ? function ($) { $(require, exports, module) } : define)(function (require, exports, module, undefined) {5_[\)NOo(})5_%N]  return {}5_ N] return { }5_N]  stream: function stream()5_N]$' stream: function stream(next, stop)5_'N]'* stream: function stream(next, stop) {}5_)N])) stream: function stream(next, stop) { }5_ N]0  var value = {5_  N]2  ! value.next = next5_! N]9! " value.stop = stop5_ "!N]E" # return value5_!#"N]I5_"$#N]I5_#$N]J5_ Mp ?exports.compa = function test(assert, done, stream, expected) {5