GODRIVER-2489 Return error if createPipelineOptionsDoc() fails (#1035)

Co-authored-by: Preston Vasquez <[email protected]>
Co-authored-by: pengzhenyi <[email protected]>
Co-authored-by: Benjamin Rewis <[email protected]>

Author: 3 people

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 {