FM / test

/usr/local/lib/node_modules/pm2/node_modules/lazy/test/

/usr/local/lib/node_modules/pm2/node_modules/lazy/test

Name	Size	Mode	Actions
bucket.js	989	0644	edit dl rm
complex.js	1164	0644	edit dl rm
custom.js	698	0644	edit dl rm
em.js	715	0644	edit dl rm
filter.js	569	0644	edit dl rm
foldr.js	540	0644	edit dl rm
forEach.js	612	0644	edit dl rm
head.js	491	0644	edit dl rm
join.js	518	0644	edit dl rm
lines.js	2296	0644	edit dl rm
map.js	569	0644	edit dl rm
pipe.js	884	0644	edit dl rm
product.js	519	0644	edit dl rm
range.js	7128	0644	edit dl rm
skip.js	541	0644	edit dl rm
sum.js	492	0644	edit dl rm
tail.js	538	0644	edit dl rm
take.js	518	0644	edit dl rm
takeWhile.js	554	0644	edit dl rm

Edit: /usr/local/lib/node_modules/pm2/node_modules/lazy/test/lines.js (2296B)

var assert = require('assert');
var Lazy = require('..');
var EventEmitter = require('events').EventEmitter;

exports['buffered lines'] = function () {
    var lazy = Lazy();
    var joined = false;
    lazy.lines
        .forEach(function (line) {
            assert.ok(line instanceof Buffer);
            assert.ok(!line.toString().match(/\n/));
            assert.ok(line.length > 0);
        })
        .join(function (lines) {
            assert.deepEqual(
                lines.map(function (x) { return x.toString() }),
                'foo bar baz quux moo'.split(' ')
            );
            joined = true;
        });
    ;
    
    setTimeout(function () {
        lazy.push(new Buffer('foo\nbar'));
        lazy.push(new Buffer('\nbaz\nquux\nmoo'));
        lazy.push(new Buffer(''));
        lazy.push(new Buffer('\ndoom'));
        lazy.end();
        assert.ok(joined);
    }, 50);
};

exports['string lines'] = function () {
    var lazy = Lazy();
    var joined = false;
    lazy.lines
        .forEach(function (line) {
            assert.ok(line instanceof Buffer);
            assert.ok(!line.toString().match(/\n/));
            assert.ok(line.length > 0);
        })
        .join(function (lines) {
            assert.deepEqual(
                lines.map(function (x) { return x.toString() }),
                'foo bar baz quux moo'.split(' ')
            );
            joined = true;
        });
    ;
    
    setTimeout(function () {
        lazy.push('foo\nbar');
        lazy.push('\nbaz\nquux\nmoo');
        lazy.push('');
        lazy.push('\ndoom');
        lazy.end();
        assert.ok(joined);
    }, 50);
};

exports.endStream = function () {
    var to = setTimeout(function () {
        assert.fail('never finished');
    }, 2500);
    
    var em = new EventEmitter;
    var i = 0;
    var lines = [];
    Lazy(em).lines.forEach(function (line) {
        i ++;
        lines.push(line);
        if (i == 2) {
            clearTimeout(to);
            assert.eql(lines.map(String), [ 'foo', 'bar' ]);
        }
    });
    
    setTimeout(function () {
        em.emit('data', 'fo');
    }, 100);
    
    setTimeout(function () {
        em.emit('data', 'o\nbar');
    }, 150);
    
    setTimeout(function () {
        em.emit('end');
    }, 200);
};