Observable
        .create(new ObservableOnSubscribe<Integer>() {
            @Override
            public void subscribe(ObservableEmitter<Integer> e) throws Exception {
                e.onNext(1);
                Thread.sleep(200);
                e.onNext(2);
                Thread.sleep(200);
                e.onNext(3);
                Thread.sleep(200);
                e.onNext(4);
                Thread.sleep(200);
                e.onNext(5);
                Thread.sleep(200);
                e.onNext(6);
                Thread.sleep(1500);
                e.onNext(7);
            }
        })
        .timeout(500, TimeUnit.MILLISECONDS)
        .subscribe(new Observer<Integer>() {
            @Override
            public void onSubscribe(Disposable d) {
                Log.d(TAG, "onSubscribe");
            }
            @Override
            public void onNext(Integer value) {
                Log.d(TAG, "onNext value=" + value);
            }
            @Override
            public void onError(Throwable e) {
                Log.d(TAG, "onError");
            }
            @Override
            public void onComplete() {
                Log.d(TAG, "onComplete");
            }
        });