app-rxjs.js

var Rx = require('rx');

var stream1 = Rx.Observable.from(['a', 'b', 'c']);
var stream2 = Rx.Observable.from([1, 2, 3]);

var combined = stream1.combineLatest(stream2, function (x, y) {
  return x + y;
});

combined.subscribe(function (v) {
  console.log(v);
});

/*
$ node app-rxjs.js
a1
b1
b2
c2
c3
*/

app.js

var Bacon = require('baconjs');

var stream1 = Bacon.fromArray(['a', 'b', 'c']);
var stream2 = Bacon.fromArray([1, 2, 3]);

var combined = Bacon.combineWith(function(x, y) {
  return x + y;
}, stream1, stream2).changes();

combined.onValue(function (v) {
  console.log(v);
});

/* output
$ node app.js
c1
c2
c3
*/