Update change_stream.go

tdq45gj · tdq45gj · commit e89d17595bf2 · 2024-11-27T18:35:11.000-05:00
diff --git a/internal/verifier/change_stream.go b/internal/verifier/change_stream.go
@@ -116,6 +116,7 @@ func (verifier *Verifier) StartChangeEventHandler(ctx context.Context, reader *C
 				}
 				err := verifier.HandleChangeStreamEvents(ctx, batch, reader.readerType)
 				if err != nil {
+					reader.ChangeStreamErrChan <- err
 					return err
 				}
 			}

Original file line number	Diff line number	Diff line change
`@@ -116,6 +116,7 @@ func (verifier Verifier) StartChangeEventHandler(ctx context.Context, reader C`
`116`	`116`	`}`
`117`	`117`	`err := verifier.HandleChangeStreamEvents(ctx, batch, reader.readerType)`
`118`	`118`	`if err != nil {`
	`119`	`+ reader.ChangeStreamErrChan <- err`
`119`	`120`	`return err`
`120`	`121`	`}`
`121`	`122`	`}`