Uploaded image for project: 'Java Driver'
  1. Java Driver
  2. JAVA-3791

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

    • Type: Icon: Bug Bug
    • Resolution: Duplicate
    • Priority: Icon: Major - P3 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.

            Assignee:
            ross@mongodb.com Ross Lawley
            Reporter:
            h1023263204@gmail.com Yue Gu
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

              Created:
              Updated:
              Resolved: