diff --git a/internal/pkg/agent/application/coordinator/coordinator_test.go b/internal/pkg/agent/application/coordinator/coordinator_test.go index 357d65edba0..cd813e7a921 100644 --- a/internal/pkg/agent/application/coordinator/coordinator_test.go +++ b/internal/pkg/agent/application/coordinator/coordinator_test.go @@ -341,6 +341,8 @@ func TestCoordinator_StateSubscribe_BlockedSubscriber(t *testing.T) { // active subscriber that will. This is to test that congestion in some // subscribers will not block state updates to others. coord.StateSubscribe(ctx) + coord.StateSubscribe(ctx) + coord.StateSubscribe(ctx) activeSub := coord.StateSubscribe(ctx) stateChangeCount := 0 for {