Remove channel capacity constraint in test helper to avoid missing messages

Signed-off-by: Thane Thomson <connect@thanethomson.com>
This commit is contained in:
Thane Thomson
2022-04-13 13:01:49 -04:00
parent 35aa879c7e
commit 532a0f9719

View File

@@ -380,7 +380,7 @@ func subscribeToVoter(ctx context.Context, t *testing.T, cs *State, addr []byte,
vt[t] = struct{}{}
}
ch := make(chan tmpubsub.Message, 1)
ch := make(chan tmpubsub.Message)
if err := cs.eventBus.Observe(ctx, func(msg tmpubsub.Message) error {
vote := msg.Data().(types.EventDataVote)
// we only fire for our own votes