如何使用RxJava在计时器超时之前阻止返回

Observable<Integer> timerObservable = Observable.timer(5, TimeUnit.SECONDS);
Observable<Integer> dataSourceObservable = Observable.just(1, 2, 3, 4, 5);

dataSourceObservable
    .takeUntil(timerObservable)
    .subscribe(new Observer<Integer>() {
        @Override
        public void onSubscribe(Disposable d) {
            // 订阅开始时的操作
        }

        @Override
        public void onNext(Integer integer) {
            // 处理每个事件的操作
        }

        @Override
        public void onError(Throwable e) {
            // 处理错误的操作
        }

        @Override
        public void onComplete() {
            // 处理完成的操作
        }
    });