Skip to content

Commit d66f25e

Browse files
committed
Update change_stream_test.go
1 parent 24d3881 commit d66f25e

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

internal/verifier/change_stream_test.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@ import (
1515

1616
func TestChangeStreamFilter(t *testing.T) {
1717
verifier := Verifier{}
18+
verifier.initializeChangeStreamReaders()
1819
verifier.SetMetaDBName("metadb")
1920
require.Equal(t, []bson.D{{{"$match", bson.D{{"ns.db", bson.D{{"$ne", "metadb"}}}}}}},
2021
verifier.srcChangeStreamReader.GetChangeStreamFilter())

0 commit comments

Comments
 (0)