fix test

Author: FGasper

internal/verifier/change_stream.go

@@ -178,7 +178,7 @@ func (verifier *Verifier) StartChangeStream(ctx context.Context) error {
 				Msg("Failed to extract timestamp from persisted resume token.")
 		}
 
-		logEvent.Msg("Starting change stream with persisted resume token.")
+		logEvent.Msg("Starting change stream from persisted resume token.")
 
 		opts = opts.SetStartAfter(savedResumeToken)
 	} else {

internal/verifier/change_stream_test.go

@@ -58,9 +58,11 @@ func (suite *MultiSourceVersionTestSuite) TestChangeStreamResumability() {
 	suite.Require().NoError(err)
 
 	suite.Require().NotNil(verifier2.srcStartAtTs)
+
 	suite.Assert().Equal(
-		startTs,
+		primitive.Timestamp{T: startTs.T, I: 1 + startTs.I},
 		*verifier2.srcStartAtTs,
+		"verifier2's change stream should be 1 increment further than verifier1's",
 	)
 }