-
Type: Bug
-
Resolution: Duplicate
-
Priority: Major - P3
-
None
-
Affects Version/s: 4.0.3, 4.0.4
-
Component/s: Reactive Streams
-
None
Below is a short description of my trouble, if it make any annoyance, I could write some code to repeat the problem.
When a MongoConverter threw an fatal exception(`reactor.core#Exceptions.throwIfFatal`), `com.mongodb.reactivestreams.client.internal#AbstractSubscription.onNext` catched the throwable, and check if subscriber is terminated to invoke the `onError` method, but the subscriber was canceled at `reactor.core.publisher#onNext`, as a result, nothing was passed to userland code.
I'm not sure it's the bug of reactive mongodb project or reactor project, but I believe it's not user's expecting. Please check it and at least tell me how resolve this.