Getting started

Trooba allows to structure any of your data flows into separate, independent, testable components.

Hello World

const Trooba = require('trooba');
 
const pipe = Trooba
.use(pipe => {
    pipe.on('request', request => {
        pipe.respond(`Hello ${request}`);
    });
})
.build();
 
pipe.create().request('John', (err, response) => console.log(response)); // Hello John

Let's now add a handler that modifies the name

const Trooba = require('trooba');
 
const pipe = Trooba
.use(pipe => {
    pipe.on('request', (request, next) => {
        next(`${request} and Bob`);
    });
})
.use(pipe => {
    pipe.on('request', request => {
        pipe.respond(`Hello ${request}`);
    });
})
.build();
 
pipe.create().request('John', (err, response) => console.log(response)); // Hello John and Bob

EDIT

Contributors

Helpful? You can thank these awesome people! You can also edit this doc if you see any issues or want to improve it.