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 737cee4 commit fd9a1eeCopy full SHA for fd9a1ee
1 file changed
modules/jooby-rxjava3/src/main/java/io/jooby/rxjava3/Reactivex.java
@@ -20,6 +20,7 @@
20
import io.reactivex.rxjava3.core.Maybe;
21
import io.reactivex.rxjava3.core.Observable;
22
import io.reactivex.rxjava3.core.Single;
23
+import io.reactivex.rxjava3.disposables.Disposable;
24
25
/**
26
* Rx reactive filter.
@@ -53,6 +54,9 @@ public Route.Handler apply(@NonNull Route.Handler next) {
53
54
maybe.subscribe(new RxSubscriber(ctx));
55
// Return context to mark as handled
56
return ctx;
57
+ } else if (result instanceof Disposable) {
58
+ // Return context to mark as handled
59
+ return ctx;
60
}
61
return result;
62
};
0 commit comments