- .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()