|
@ -351,8 +351,6 @@ func (r *Reactor) broadcastHasVoteMessage(ctx context.Context, vote *types.Vote) |
|
|
// internal pubsub defined in the consensus state to broadcast them to peers
|
|
|
// internal pubsub defined in the consensus state to broadcast them to peers
|
|
|
// upon receiving.
|
|
|
// upon receiving.
|
|
|
func (r *Reactor) subscribeToBroadcastEvents() { |
|
|
func (r *Reactor) subscribeToBroadcastEvents() { |
|
|
onStopCh := r.state.getOnStopCh() |
|
|
|
|
|
|
|
|
|
|
|
err := r.state.evsw.AddListenerForEvent( |
|
|
err := r.state.evsw.AddListenerForEvent( |
|
|
listenerIDConsensus, |
|
|
listenerIDConsensus, |
|
|
types.EventNewRoundStepValue, |
|
|
types.EventNewRoundStepValue, |
|
|