pipe

pipeable.js

const fs = require('fs');

const self = src => src;
const pipeAble = src => ({
    pipe: func => pipeAble(func(src)),
    track: (fmt = self) => pipeAble(console.log(fmt(src)) || src),
    ensureObjectNotNull: placeHolder => pipeAble(src || placeHolder || {}),
    ensureArrayNotNull: placeHolder => pipeAble(src || placeHolder || []),
    redirect: dest => pipeAble((dest === console.log ? console.log(src) : fs.writeFileSync(dest, src)) || src),
    strikeWhenBlanking: message => {
        if (src) {
            return pipeAble(src);
        } else {
            throw new Error(message);
        }
    },
    get: () => src
});

const plusOne = i => i + 1;

const result = pipeAble(1).pipe(plusOne).pipe(plusOne).pipe(plusOne).pipe(plusOne).get();

console.log(result); // 5

const person = {
    familyName: 'zhuang',
    lastName: 'grant'
}

const fullname = ({ familyName, lastName }) => [lastName, familyName].join(' ');

const toUpperCase = str => str.toUpperCase();

const upperCaseFullname = pipeAble(person).pipe(fullname).pipe(toUpperCase).get();

console.log(upperCaseFullname); // GRANT ZHUANG