As multiple requests for data can occur before data is available, then implementations of AbstractSubscription must handle when the Subscriptions completed state.
Currently, completed defaults to true - so there is a race condition on multiple calls to request between the requesting initial data and then the processing of results that looks at the completed state. If results haven't come in it shortcuts to calling onComplete.
- related to
-
JAVA-1931 com.mongodb.MongoSocketWriteException when using Async driver + Netty
- Closed