Skip to content

Commit a13cea7

Browse files
committed
fix StartChangeStream
1 parent 07e2691 commit a13cea7

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

internal/verifier/change_stream_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ func (suite *MultiSourceVersionTestSuite) TestStartAtTimeNoChanges() {
4040
suite.Require().NoError(err)
4141
origStartTs := sess.OperationTime()
4242
suite.Require().NotNil(origStartTs)
43-
err = verifier.StartChangeStream(ctx, *origStartTs)
43+
err = verifier.StartChangeStream(ctx)
4444
suite.Require().NoError(err)
4545
suite.Require().Equal(verifier.srcStartAtTs, origStartTs)
4646
verifier.changeStreamEnderChan <- struct{}{}
@@ -60,7 +60,7 @@ func (suite *MultiSourceVersionTestSuite) TestStartAtTimeWithChanges() {
6060
suite.Require().NoError(err)
6161
origStartTs := sess.OperationTime()
6262
suite.Require().NotNil(origStartTs)
63-
err = verifier.StartChangeStream(ctx, *origStartTs)
63+
err = verifier.StartChangeStream(ctx)
6464
suite.Require().NoError(err)
6565
suite.Require().Equal(verifier.srcStartAtTs, origStartTs)
6666
_, err = suite.srcMongoClient.Database("testDb").Collection("testColl").InsertOne(

0 commit comments

Comments
 (0)