Skip to content

Commit

Permalink
fix comment
Browse files Browse the repository at this point in the history
  • Loading branch information
frairon committed Sep 26, 2023
1 parent b929f5e commit 4a3cd72
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion systemtest/processor_visit_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -198,16 +198,19 @@ func TestProcessorVisit(t *testing.T) {
visitErr error
visitDone = make(chan struct{})
)
// pass wrong type to visitor -> which will be passed to the visit --> will panic

// start the visitor
go func() {
defer close(visitDone)
visitErr = proc.VisitAll(visitCtx, "visitor", int64(25))
}()

// wait half of what the processor takes for message to process, so we can stop it in the middle
time.Sleep(500 * time.Millisecond)
// stop the visit
visitCancel()

// wait for visiting done
<-visitDone
require.ErrorContains(t, visitErr, "canceled")

Expand Down

0 comments on commit 4a3cd72

Please sign in to comment.