apipe

Functional pipes and promise based pipes.

const assert = require('assert');
const {pipe, promisePipe} = require('..');

describe('test', () => {
    it('pipe', () => {

        let addOne = (it) => it + 1;
        let addTwo = (it) => it + 2;

        let xpipe = pipe(addOne, addTwo);

        assert.equal(xpipe('hello'), 'hello12');
        assert.equal(xpipe(5), 8);
    });

    it('pipe / array constructor', () => {

        let addOne = (it) => it + 1;
        let addTwo = (it) => it + 2;

        let xpipe = pipe([addOne, addTwo], addOne, [addTwo, addTwo]);

        assert.equal(xpipe('hello'), 'hello12122');
        assert.equal(xpipe(10), 18);
    });

    it('promise pipe', () => {

        let timeout = (time) => new Promise((resolve, reject) => setTimeout(resolve, time));

        let addOne = (it) => Promise.resolve()
            .then(() => timeout(1))
            .then(() => it + 1);

        let addTwo = (it) => it + 2;

        let xpipe = promisePipe(addOne, addTwo);

        return xpipe('hello')
            .then((result) => assert.equal(result, 'hello12'))
            .then(() => xpipe(10))
            .then((result) => assert.equal(result, 13))
            .then(() => xpipe('done'))
            .then((result) => assert.equal(result, 'done12'));
    })

    it('promise pipe / with array constructor', () => {
        let addOne = (it) => it + 1;
        let addTwo = (it) => it + 2;

        let xpipe = promisePipe(addOne, addTwo, [addOne, addTwo, addTwo]);

        return xpipe('hello')
            .then((result) => assert.equal(result, 'hello12122'))
            .then(() => xpipe(10))
            .then((result) => assert.equal(result, 18))
    })
});