entries

entries.js

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', {
          messages: messages
        });
      }
    });
});