AbstractSubscription#onError must call the onError method of the observer
@@ -65,9 +65,13 @@ final class MongoIterableSubscription<TResult> extends AbstractSubscription<TRes
@Override
void postTerminate() {
+ try {
if (batchCursor != null) {
batchCursor.close();
}
+ } catch (Exception e) {
+ // do nothing
+ }
}
@Override
