dispose.java

final Observable<String> o = Observable.create(new ObservableOnSubscribe<String>() {
    @Override
    public void subscribe(ObservableEmitter<String> e) throws Exception {
        for(int i=0; i<10; i++) {
            if(e.isDisposed()) break;
            // make request here...
            e.onNext(String.valueOf(i));
            try {
                Thread.sleep(1000);
            } catch(InterruptedException ie) {}
        }
        e.onComplete();
    }
});