onNext errors should not throw if the subscription has been cancelled.

XMLWordPrintableJSON

    • Type: Bug
    • Resolution: Duplicate
    • Priority: Major - P3
    • None
    • Affects Version/s: 4.0.3, 4.0.4
    • Component/s: Reactive Streams
    • None
    • None
    • None
    • None
    • None
    • None
    • None
    • 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.

              Assignee:
              Ross Lawley
              Reporter:
              Yue Gu
              None
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

                Created:
                Updated:
                Resolved: