We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ab154c4 commit a85badfCopy full SHA for a85badf
internal/verifier/change_stream.go
@@ -366,7 +366,8 @@ func (verifier *Verifier) createChangeStream(
366
367
// StartChangeStream starts the change stream.
368
func (verifier *Verifier) StartChangeStream(ctx context.Context) error {
369
- // Result seems a bit simpler than messing with 2 separate channels.
+ // Rather than Result we could have separate Timestamp and error channels,
370
+ // but the single channel seems simpler/cleaner.
371
resultChan := make(chan mo.Result[primitive.Timestamp])
372
373
go func() {
0 commit comments