1. Added LINQ-like methods for IObservable<T> in order to improve composability