TimeoutObservable.java

        Observable.just(1l, 2l, 3l, 4l, 5l, 6l)
                .timer(1, TimeUnit.SECONDS)
                .timeout(500, TimeUnit.MILLISECONDS)
                .subscribe(new Observer<Long>() {
                    @Override
                    public void onSubscribe(Disposable d) {

                    }

                    @Override
                    public void onNext(Long aLong) {
                        System.out.println("onNext: " + aLong);
                    }

                    @Override
                    public void onError(Throwable e) {
                        e.printStackTrace();
                        System.out.println("onError: ");
                    }

                    @Override
                    public void onComplete() {

                    }
                });