一、描述

对原始Observable的一个镜像，如果过了一个指定的时长仍没有发射数据，它会发一个错误通知。

如果原始Observable过了指定的一段时长没有发射任何数据，Timeout操作符会以一个onError通知终止这个Observable。

RxJava中的实现为timeout，但是有好几个变体。

第一个变体接受一个时长参数，每当原始Observable发射了一项数据，timeout就启动一个计时器，如果计时器超过了指定指定的时长而原始Observable没有发射另一项数据，timeout就抛出TimeoutException，以一个错误通知终止Observable。

这个timeout默认在computation调度器上执行，你可以通过参数指定其它的调度器。

二、示意图

timeout

三、示例代码

Observable.create(new Observable.OnSubscribe<Integer>() {
    @Override
    public void call(Subscriber<? super Integer> subscriber) {
        for (int i = 1; i < 4; i++) {
            try {
                Thread.sleep(100 * i);
            } catch (InterruptedException e) {
                subscriber.onError(e);
            }
            subscriber.onNext(i);
        }
        subscriber.onCompleted();
    }
})
    .timeout(250, TimeUnit.MILLISECONDS)
    .subscribeOn(Schedulers.newThread())
    .subscribe(new Subscriber<Integer>() {
        @Override
        public void onCompleted() {
            System.out.println("onCompleted.");
        }

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

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