Observable<Integer> observableString = Observable.create(new Observable.OnSubscribe<Integer>() {
public void call(Subscriber<? super Integer> observer) {
for (int i = 0; i < 5; i++) {
Subscription subscriptionPrint = observableString.subscribe(new Observer<Integer>() {
public void onCompleted() {
System.out.println("Observable completed");
public void onError(Throwable e) {
System.out.println("Oh,no! Something wrong happened!");
public void onNext(Integer item) {
System.out.println("Item is " + item);