Skip to content

Commit e323368

Browse files
committed
Minor comment fixes
1 parent c2ebb6f commit e323368

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

tests/load/listen/newhead.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ func subscriptionChToSignal(listenStop <-chan struct{}, listenDone, ready chan<-
7474
}
7575
}
7676

77-
// makeRunErrCh makes sure the [newHeadNotifyer] fully stops when
77+
// makeRunErrCh makes sure the [headNotifier] fully stops when
7878
// a subscription error is encountered.
7979
func (n *headNotifier) makeRunErrCh() <-chan error {
8080
errCh := make(chan error)

tests/load/orchestrate/burst.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ func (o *BurstOrchestrator[T, U]) Execute(ctx context.Context) error {
7676
observerCancel()
7777
}()
7878

79-
// blocks until either all of the issuers have finished or our context
79+
// blocks until either all of the observers have finished or our context
8080
// is cancelled signalling for early termination (with an error)
8181
if err := observerGroup.Wait(); err != nil {
8282
return fmt.Errorf("observers: %w", err)

0 commit comments

Comments
 (0)