VimŸUnDoå“ö$äï™?¢ds�f49®�ƺãY¢G'A¶H7{)N)var streamer = require('../streamer.js'), #]]]]N_Z#_ÐÿÿÿÿMî8ôõI% test(assert, done, head(empty), [])5�_ÐÿÿÿÿMî8÷õ I5exports['test head empty'] = function(assert, done) {5�_ÐÿÿÿÿMî9õIexports['test head smaller stream'] = function(assert, done) {5�_Ð ÿÿÿÿMî9EõI1 test(assert, done, head(numbers, 5), [1, 2, 3])5�_Ð /ÿÿÿÿMî9IõI1 test(assert, done, tail(numbers, 5), [1, 2, 3])5�_Ð  &ÿÿÿÿMî9Yõ%'I2 test(assert, done, head(stream, 3), [ 5, 4, 3 ])5�_Ð &#ÿÿÿÿMî9^õ%'I2 test(assert, done, tail(stream, 3), [ 5, 4, 3 ])5�_Ð&'ÿÿÿÿMî9aõ%'I/ test(assert, done, tail(stream), [ 5, 4, 3 ])5�_Ð&)ÿÿÿÿMî9dõ%'I, test(assert, done, tail(stream), [ 4, 3 ])5�_Ð&/ÿÿÿÿMî9hõ%'I2 test(assert, done, tail(stream), [ 4, 3, 2, 1 ])5�_Ð&2ÿÿÿÿMî9kõ%'I5 test(assert, done, tail(stream), [ 4, 3, 2, 1, 0 ])5�_ÐÿÿÿÿMî9qõI?exports['test head of async stream'] = function(assert, done) {5�_Ð) ÿÿÿÿMî9zõ(*ICexports['test head before stream error'] = function(assert, done) {5�_Ð5 ÿÿÿÿMî9} õ46I@exports['test head on broken stream'] = function(assert, done) {5�_Ð) ÿÿÿÿMî9âõ(*IDexports['-test head before stream error'] = function(assert, done) {5�_Ð)ÿÿÿÿMî9ãõ(*ICexports['test head before stream error'] = function(assert, done) {5�_Ð).ÿÿÿÿMî9è õ(*IKexports['test stream error before stream error'] = function(assert, done) {5�_Ð) ÿÿÿÿMî9ò õ(*ICexports['test stream error before tail'] = function(assert, done) {5�_Ð) ÿÿÿÿMî9öõ(*IDexports['-test stream error before tail'] = function(assert, done) {5�_Ð)!ÿÿÿÿMî9þõ(*ICexports['test stream error before tail'] = function(assert, done) {5�_Ð)ÿÿÿÿMî: õ(*I>exports['test stream error i tail'] = function(assert, done) {5�_Ð2ÿÿÿÿMî:õ13I0 test(assert, done, head(stream, 3), [3, 2, 1])5�_Ð1ÿÿÿÿMî: õ13J õ13I5�_Ð 2ÿÿÿÿMî:õ13J tail()5�_Ð! 2ÿÿÿÿMî:õ13J tail(stream)5�_Ð "!2ÿÿÿÿMî:õ13J tail(stream)()5�_Ð!#"2ÿÿÿÿMî:õ13J tail(stream)(function {})5�_Ð"$#2ÿÿÿÿMî:#õ13J) tail(stream)(function { buffer.push()})5�_Ð#%$2ÿÿÿÿMî:$õ13J+ tail(stream)(function() { buffer.push()})5�_Ð$&%2/ÿÿÿÿMî:'õ13J2 tail(stream)(function(element) { buffer.push()})5�_Ð%'&27ÿÿÿÿMî:)õ13J9 tail(stream)(function(element) { buffer.push(element)})5�_Ð&('29ÿÿÿÿMî:+õ13J: tail(stream)(function(element) { buffer.push(element) })5�_Ð')(2JÿÿÿÿMî:/õ13JK tail(stream)(function(element) { buffer.push(element) }, function stop())5�_Ð(*)2LÿÿÿÿMî:0õ14JN tail(stream)(function(element) { buffer.push(element) }, function stop() {})5�_Ð)+*2IÿÿÿÿMî:3õ13KL tail(stream)(function(element) { buffer.push(element) }, function stop() {5�_Ð*,+2ÿÿÿÿMî:8õ13KQ tail(stream)(function(element) { buffer.push(element) }, function stop(error) {5�_Ð+-,2ÿÿÿÿMî::õ13KL tail(stream)(function(el) { buffer.push(element) }, function stop(error) {5�_Ð,.-2ÿÿÿÿMî:<õ13KK tail(stream)(function($) { buffer.push(element) }, function stop(error) {5�_Ð-/.20ÿÿÿÿMî:?õ13KK tail(stream)(function(x) { buffer.push(element) }, function stop(error) {5�_Ð.0/2ÿÿÿÿMî:Eõ13KE tail(stream)(function(x) { buffer.push(x) }, function stop(error) {5�_Ð/10) ÿÿÿÿMî:Mõ)+L õ)+K5�_Ð0215ÿÿÿÿMî:Sõ450 test(assert, done, head(stream, 3), [3, 2, 1])5�_Ð1323ÿÿÿÿMî:Võ35L õ35K5�_Ð2434ÿÿÿÿMî:Yõ35L assert.equal()5�_Ð3544!ÿÿÿÿMî:]õ35L# assert.equal(error.message, "")5�_Ð4654'ÿÿÿÿMî:aõ35L( assert.equal(error.message, "Boom!")5�_Ð5764&ÿÿÿÿMî:dõ35L* assert.equal(error.message, "Boom!", )5�_Ð6874 ÿÿÿÿMî:eõ35L* assert.equal(error.message, "Boom!', )5�_Ð798.$ÿÿÿÿMî:gõ-/L- if (!x) return stop(new Error("Boom!"))5�_Ð8:9.*ÿÿÿÿMî:hõ-/L- if (!x) return stop(new Error('Boom!"))5�_Ð9;:ÿÿÿÿMî:qõ L "use strict";5�_Ð:<; ÿÿÿÿMî:rõ L 'use strict";5�_Ð;=<=$ÿÿÿÿMî:xõ<>L- if (!x) return stop(new Error("Boom!"))5�_Ð<>==*ÿÿÿÿMî:yõ<>L- if (!x) return stop(new Error('Boom!"))5�_Ð=?>C ÿÿÿÿMî:}õBDLM assert.equal(error.message, "Boom!", "error propagated to mapped stream")5�_Ð>@?C&ÿÿÿÿMî:~õBDLM assert.equal(error.message, 'Boom!", "error propagated to mapped stream")5�_Ð?A@C)ÿÿÿÿMî:€õBDLM assert.equal(error.message, 'Boom!', "error propagated to mapped stream")5�_Ð@BACKÿÿÿÿMî:ƒõBDLM assert.equal(error.message, 'Boom!', 'error propagated to mapped stream")5�_ÐACBDMÿÿÿÿMî:…õCELO assert.deepEqual(buffer, [3, 2, 1], "all values were yielded before error")5�_ÐBDCD(ÿÿÿÿMî:ˆõCELO assert.deepEqual(buffer, [3, 2, 1], "all values were yielded before error')5�_ÐCED4)ÿÿÿÿMî:�õ35L* assert.equal(error.message, 'Boom!', )5�_ÐDFE4*ÿÿÿÿMî:‘õ35L, assert.equal(error.message, 'Boom!', '')5�_ÐEGF4AÿÿÿÿMî:™õ46M õ46L5�_ÐFHG5ÿÿÿÿMî:œõ46M assert.deepEqual()5�_ÐGIH5ÿÿÿÿMî:žõ46M assert.deepEqual(buffer, [])5�_ÐHJI5 ÿÿÿÿMî:¦õ46M' assert.deepEqual(buffer, [3, 2, 1])5�_ÐIKJ5ÿÿÿÿMî:¨õ46M% assert.deepEqual(buffer, [ 2, 1])5�_ÐJLK5"ÿÿÿÿMî:©õ46M$ assert.deepEqual(buffer, [2, 1])5�_ÐKML5#ÿÿÿÿMî:®õ46M$ assert.deepEqual(buffer, [2, 1])5�_ÐLNM5&ÿÿÿÿMî:¯õ46M( assert.deepEqual(buffer, [2, 1], '')5�_ÐMON5MÿÿÿÿMî:Æõ57N õ57M5�_ÐNPODÿÿÿÿMî:ÖõCENM head(stream, 5)(function next(x) { buffer.push(x) }, function stop(error) {5�_ÐOQPF%ÿÿÿÿMî:ÞõEGNO assert.deepEqual(buffer, [3, 2, 1], 'all values were yielded before error')5�_ÐPRQF%ÿÿÿÿMî:áõEGNH assert.deepEqual(buffer, [], 'all values were yielded before error')5�_ÐQSRF1ÿÿÿÿMî:äõEGNG assert.deepEqual(buffer, [], 'no values were yielded before error')5�_ÐRTS: ÿÿÿÿMî:ëõ9;NAexports['-test head on broken stream'] = function(assert, done) {5�_ÐSUT:ÿÿÿÿMî:ìõ9;N@exports['test head on broken stream'] = function(assert, done) {5�_ÐTVU:$ÿÿÿÿMî:õõ9;NHexports['test stream error on broken stream'] = function(assert, done) {5�_ÐUWV:(ÿÿÿÿMî:÷õ9;NEexports['test stream error before stream'] = function(assert, done) {5�_ÐVXW #ÿÿÿÿM õ N&var streamer = require('../streamer'),5�_ÐWYXL ÿÿÿÿMî‘¢õKMN require("test").run(exports);5�_ÐXZYLÿÿÿÿMî‘£!õKMN require('test").run(exports);5�_ÐY[ZÿÿÿÿNO–RõNˆ(typeof define === "undefined" ? function ($) { $(require, exports, module) } : define)(function (require, exports, module, undefined) {5�_ÐZ\[NÿÿÿÿNO–TõM})5�_Ð[]\LÿÿÿÿNO–V"õKMN require('test').run(exports);5�_Ð\] #ÿÿÿÿN_Z#õ N)var streamer = require('../streamer.js'),5�çª