Add createobservable

Create RxJava Observable