GODRIVER-2489 Return error if createPipelineOptionsDoc() failed in ex…

…ecuteOperation() (#1020) Co-authored-by: Preston Vasquez <prestonvasquez@icloud.com>
mongodb · Jul 28, 2022 · a006621 · a006621
1 parent f1bb3c7
commit a006621
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/mongo/change_stream.go b/mongo/change_stream.go
@@ -257,6 +257,9 @@ func (cs *ChangeStream) executeOperation(ctx context.Context, resuming bool) err
 		cs.replaceOptions(cs.wireVersion)
 
 		csOptDoc := cs.createPipelineOptionsDoc()
+		if cs.err != nil {
+			return cs.Err()
+		}
 		pipIdx, pipDoc := bsoncore.AppendDocumentStart(nil)
 		pipDoc = bsoncore.AppendDocumentElement(pipDoc, "$changeStream", csOptDoc)
 		if pipDoc, cs.err = bsoncore.AppendDocumentEnd(pipDoc, pipIdx); cs.err != nil {