Источники данных

Из событий
$('.button').stream('click')
Из коллбэка
Warden.makeStream(function(emit){
  $('.button').click(function(e){
    emit('hello');
  });
});
Прослушивание
stream.listen(callback)

map

original
stream.map('value')
stream.map('.clientX')
stream.map('.toString()')
stream.map('@width()')
Массивы
stream.map(['a', 'b']).nth(1)

Фильтры

filter

stream
  .map(function(){
    return Math.random()*100>>0; 
  })
  .filer(function(val){
    return val > 50;
  })

skip/take

stream.skip(3).take(3)

equals

stream
  .map(function(){
    return Math.round(Math.random())
  })
  .equals(1)

Композиции

Слияние

red.merge(blue)

Синхронизация

red.sync(blue)

Combine

red.map(1).combine(blue.map(2), function(a, b){
  return (a || 0) + ( b || 0);
});

Resolve

red.map(random).resolve(blue.map(random), function(a, b){
  return a > b ? a : b;
});