-
Type:
Bug
-
Resolution: Duplicate
-
Priority:
Major - P3
-
None
-
Affects Version/s: None
-
Component/s: Change Streams, Reactive Streams
-
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.
- depends on
-
JAVA-3813 Replace internal use of callbacks with Reactor in mongodb-driver-reactivestreams module
-
- Closed
-