AbstractSubscription#onError must call the onError method of the obse…

…rver JAVARS-216
mongodb · Nov 4, 2019 · 6e06585 · 6e06585
1 parent 234532c
commit 6e06585
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/driver-async/src/main/com/mongodb/async/client/MongoIterableSubscription.java b/driver-async/src/main/com/mongodb/async/client/MongoIterableSubscription.java
@@ -65,8 +65,12 @@ boolean checkCompleted() {
 
     @Override
     void postTerminate() {
-        if (batchCursor != null) {
-            batchCursor.close();
+        try {
+            if (batchCursor != null) {
+                batchCursor.close();
+            }
+        } catch (Exception e) {
+            // do nothing
         }
     }