Add to call of callback if error raise on decoding of document

evgzakharov · rozza · commit 719b9d13cac9 · 2020-03-19T15:18:00.000Z
JAVA-3644
diff --git a/driver-core/src/main/com/mongodb/internal/operation/AsyncChangeStreamBatchCursor.java b/driver-core/src/main/com/mongodb/internal/operation/AsyncChangeStreamBatchCursor.java
@@ -173,7 +173,12 @@ public void onResult(final List<RawBsonDocument> rawDocuments, final Throwable t
                             );
                             return;
                         }
-                        results.add(rawDocument.decode(changeStreamOperation.getDecoder()));
+                        try {
+                            results.add(rawDocument.decode(changeStreamOperation.getDecoder()));
+                        } catch (Exception e) {
+                            callback.onResult(null, e);
+                            return;
+                        }
                     }
                     resumeToken = rawDocuments.get(rawDocuments.size() - 1).getDocument("_id");
                     callback.onResult(results, null);

Original file line number	Diff line number	Diff line change
`@@ -173,7 +173,12 @@ public void onResult(final List<RawBsonDocument> rawDocuments, final Throwable t`
`173`	`173`	`);`
`174`	`174`	`return;`
`175`	`175`	`}`
`176`		`- results.add(rawDocument.decode(changeStreamOperation.getDecoder()));`
	`176`	`+ try {`
	`177`	`+ results.add(rawDocument.decode(changeStreamOperation.getDecoder()));`
	`178`	`+ } catch (Exception e) {`
	`179`	`+ callback.onResult(null, e);`
	`180`	`+ return;`
	`181`	`+ }`
`177`	`182`	`}`
`178`	`183`	`resumeToken = rawDocuments.get(rawDocuments.size() - 1).getDocument("_id");`
`179`	`184`	`callback.onResult(results, null);`