observable.cool

examples

• .take()
• .skip()
• .map()
• .filter()
• .filter().map()
• .pluck()
• Rx.Observable.timer()
• .pausable()
• [.takeUntil() / .skipUntil()] // TODO
• [.takeWhile() / .skipWhile()] // TODO
• .startWith()
• .share()
• .scan()
• .reduce()
• .sum()
• .count()
• .withLatestFrom() / .combineLatest()
• .flatMap()
• .switch()