Implemented client side IObservable<T> support