StreamObservable<T> constructor

StreamObservable<T>()