jocoone

var pipeline1 = Rx.Observable.interval(500); // sends a waterdrop every 0,5s
var pipeline2 = Rx.Observable.interval(1000); // sends a waterdrop every second

pipeline1
	.merge(pipeline2)
  	.filter(drop => drop % 2 === 0)
  	.map(drop => drop + 100)
	.forEach(d => console.log(d));

jocoone

Rx.Observable.range(0, 10) //representing the pipeline
       .filter(drop => drop % 2 === 0)
       .map(drop => drop + 2)
       .sum() // as in putting water in a bucket
       .subscribe((bucket) => console.log(bucket)); // 30