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

ChangeStream Publisher's cursor does not closed after .cancel()

XMLWordPrintableJSON

    • Type: Icon: Bug Bug
    • Resolution: Duplicate
    • Priority: Icon: Major - P3 Major - P3
    • None
    • Affects Version/s: None
    • Component/s: Change Streams, Reactive Streams
    • Labels:
      None
    • Environment:
      MongoDB 4.0.12, org.mongodb:mongodb-driver-reactivestreams:4.0.5

      We start a Change Stream Publisher on a collection.

      Do not execute any operation on this collection at that time.

      The AsyncChangeStreamBatchCursor would call getMore command every second.

      Now we invoke subscription.cancel() method.

      The AsyncChangeStreamBatchCursor should be closed, but it doesn't.

      The property isOperationInProgress == true , isClosePending == true and the Cursor continue in getMore loop, never closed.

       

        1. test_app.java
          4 kB

            Assignee:
            ross@mongodb.com Ross Lawley
            Reporter:
            a471558277@gmail.com Ricky Chen
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

              Created:
              Updated:
              Resolved: