Timeout
运算符on
RxJava2
Observer
?
我正在创建一个网络请求并将其结果作为
Observable
. 如果有超时,我想取消网络请求。我不想用
OnError
我的代码是这样的:
public Single<String> createSingle() {
return Single.fromCallable(() -> {
Task<ApiResponse> result = getApiResult();
Tasks.await(result);
return result.getResult();
});
}
我知道
Single.fromCallable
会传播任何
Exceptions
,我不知道如何取消
result
如果有
超时