We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7d65291 commit 592b991Copy full SHA for 592b991
src/main/java/io/reactivex/internal/operators/completable/CompletableFromCallable.java
@@ -18,6 +18,7 @@
18
import io.reactivex.*;
19
import io.reactivex.disposables.*;
20
import io.reactivex.exceptions.Exceptions;
21
+import io.reactivex.plugins.RxJavaPlugins;
22
23
public final class CompletableFromCallable extends Completable {
24
@@ -37,6 +38,8 @@ protected void subscribeActual(CompletableObserver observer) {
37
38
Exceptions.throwIfFatal(e);
39
if (!d.isDisposed()) {
40
observer.onError(e);
41
+ } else {
42
+ RxJavaPlugins.onError(e);
43
}
44
return;
45
0 commit comments