laser

var streamA = Bacon.fromNodeCallback(client, 'get', 'foo');

var streamB = streamA.flatMap(function(foo) {
  return Bacon.fromNodeCallback(client, 'post', 'bar', { data: foo });
});

streamB.onError(function(err) {
  throw err; // error from either the GET or the POST
});

laser

funFact.merge(entries).onError(function(err) {
  throw err; // an error from the call to MongoDB or our HTTP client
});

laser

entries.onValue(function() {
  // deliberate no-op
});

laser

funFact.onValue(function(fact) {
  io.emit('message', fact);
});

laser

messages.onValue(function(message) {
  io.emit('message', '' + message.author.id + ': ' + message.txt);
});

laser

connections.onValue(function(socket) {
  socket.broadcast.emit('message', 'A new user connected, with ID: ' + socket.id);
});

laser

var entries = messageWindow
  .filter(function(acc) {
    return acc.length === 20;
  });
  .flatMap(function(messages) {
    return Bacon.retry({
      retries: 10,
      delay: function() { return 100; },
      source: function() {
        return Bacon.fromNodeCallback(client, 'post', 'log', {

laser

var funFact = messageWindow
  .filter(function(acc) {
    return acc.length === 20;
  });
  .flatMap(function() {
    return Bacon.fromNodeCallback(database.getFunFact));
  });

laser

var messageWindow = messages.scan([], function(acc, message) {
  return acc.length === 20 ? [] : acc.concat(message);
});

laser

var messages = connections.flatMap(function(socket) {
  return Bacon.fromBinder(function(sink) {
    socket.on('message', function(txt) {
      sink({ author: socket, txt: txt });
    });
  });
});