This code implements pipeline pattern using ES6. It is inspired by Laravel Framework pipeline pattern.

Pipeline.js

export default class Pipeline {

    passable = null;

    pipes = [];

    method = 'handle';

    send = (passable) => {

        this.passable = passable;

        return this;
    };

    through = (pipes) => {

        this.pipes = pipes;

        return this;
    };


    via = (method) => {
        this.method = method;

        return this;
    };

    then = (destination) => {
        return this.pipes.reverse().reduce(this.carry, (passable) => destination(passable))(this.passable);
    };

    carry = (stack, pipe) => {
        return (passable) => {
            let params = [passable, stack];
            if(this.method in pipe){
                return pipe[this.method](...params);
            }
            return pipe(passable, stack);
        }
    }
}