rx-java - 接收超时操作符

Question

如果没有发出任何项目，我想在 x 秒后发出一项。我试图使用超时运算符。问题是 timeout 操作符需要之前至少执行一项才能开始倒计时。从文档:

“如果下一个项目没有在从其前任开始的指定超时时间内发出，则生成的 Observable 将开始镜像回退 Observable。”

这不是我正在寻找的行为。当我订阅我的 observable 时，如果在特定的时间段过去后之前没有任何发射的项目，我想发射一个特定的项目。

例子:

 getUserLocationFromGPS() //Sometimes I dont receive user location
.timeout(5, TimeUnit.SECONDS, Observable.just(getDefaultLocation())
.subscribe(...);

Answer 1

final Observable data = yourApi.getData().take(5, TimeUnit.SECONDS);
final Observable fallback = Observable.just("Fallback");

Observable.concat(data, fallback).firstOrError()
            .subscribe(
                    System.out::println
            );

如 yourApi.getData()不发出任何东西，那么你将从你的后备 observable 接收数据。

如 yourApi.getData() timeouts 那么你将从你的后备观察中接收数据。

如 yourApi.getData()正常发出，然后您将从它接收数据。