Functional/Reactive WIP

libstream.js

const assert = require('assert');

const stream = (name, fn) => {
    return fn;
};
module.exports.stream = stream;

const test = (stream, tests) => {
    tests.forEach((t) =>{
        t(stream, assert);
    });
    return stream;
};
module.exports.test = test;

const log = (stream) => {
    return (...args) => {
        console.log('IN ', args);
        const result = stream(...args);
        console.log('OUT', result);
        return result;
    }
};
module.exports.log = log;

const takePosArgs = (stream, argPos) => {
    return (...args) => {
        if (typeof args[0] === 'object') {
            return stream(...args);
        }
        const newArgs = [{}];
        argPos.forEach((argName, index) => {
            newArgs[0][argName] = args[index];
        });
        return stream(...newArgs);
    };
};
module.exports.takePosArgs = takePosArgs;

app.js

const { stream, test, log, takePosArgs } = require('./libstream');

let adder = stream('adder', (ev) => {
    return ev.x + ev.y;
});
adder = takePosArgs(adder, ['x', 'y']);
adder = log(adder);
adder = test(adder, [
    (s, assert) => assert(s({ x: 1, y: 2 }) === 3),
    (s, assert) => assert(s(4, 3) === 7),
]);