restore extra break

FGasper · FGasper · commit 668567c1e5d0 · 2024-11-07T16:15:57.000-05:00
diff --git a/internal/verifier/change_stream.go b/internal/verifier/change_stream.go
@@ -148,6 +148,14 @@ func (verifier *Verifier) iterateChangeStream(ctx context.Context, cs *mongo.Cha
 				}
 			}
 
+			if err != nil {
+				verifier.logger.Warn().
+					Err(err).
+					Msg("Change stream exiting due to error.")
+
+				break
+			}
+
 		default:
 			_, err = readOneChangeEvent()
 		}

Original file line number	Diff line number	Diff line change
`@@ -148,6 +148,14 @@ func (verifier Verifier) iterateChangeStream(ctx context.Context, cs mongo.Cha`
`148`	`148`	`}`
`149`	`149`	`}`
`150`	`150`
	`151`	`+ if err != nil {`
	`152`	`+ verifier.logger.Warn().`
	`153`	`+ Err(err).`
	`154`	`+ Msg("Change stream exiting due to error.")`
	`155`	`+`
	`156`	`+ break`
	`157`	`+ }`
	`158`	`+`
`151`	`159`	`default:`
`152`	`160`	`_, err = readOneChangeEvent()`
`153`	`161`	`}`