在RxJava1中执行以下操作时,onNext中的异常将重新路由到同一订户的onError中:
Observable.from(Arrays.asList("1", "22", "333", "4444")).subscribe(new Subscriber<String>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
Log.d("RxJava1", "onError: " + e.getCause());
}
@Override
public void onNext(String s) {
if (s.length() == 4) {
Integer test = null;
test.hashCode();
}
Log.d("RxJava1", s + " - " + s.length());
}
});
Run Code Online (Sandbox Code Playgroud)
输出:
D/RxJava1: 1 - 1
D/RxJava1: 22 - 2
D/RxJava1: 333 - 3
D/RxJava1: onError: null
Run Code Online (Sandbox Code Playgroud)
据我所知,在RxJava2中这样做时,此行为已更改,不再返回onError,而只是崩溃:
Observable.fromIterable(Arrays.asList("1", "22", "333", "4444")).subscribeWith(new Observer<String>() {
@Override
public void onSubscribe(Disposable d) …Run Code Online (Sandbox Code Playgroud) 一个非常简单的问题,但未能找到任何正确的答案;
在使用 Volley 作为库执行 (GET) http 请求时,是否可以设置要使用的特定端口?