some minor changes

CHANGELOG.md

@@ -14,7 +14,6 @@ FEATURES:
 - Tooling to run multiple blockchains/apps, possibly in a single process
 - State syncing (without transaction replay)
 - Add authentication and rate-limitting to the RPC
-- new unsubscribe_all WebSocket RPC endpoint
 
 IMPROVEMENTS:
 - Improve subtleties around mempool caching and logic

consensus/reactor.go

@@ -57,7 +57,7 @@ func (conR *ConsensusReactor) OnStart() error {
 	conR.Logger.Info("ConsensusReactor ", "fastSync", conR.FastSync())
 	conR.BaseReactor.OnStart()
 
-	err := conR.broadcastRoutine()
+	err := conR.startBroadcastRoutine()
 	if err != nil {
 		return err
 	}
@@ -325,10 +325,10 @@ func (conR *ConsensusReactor) FastSync() bool {
 
 //--------------------------------------
 
-// broadcastRoutine subscribes for new round steps, votes and proposal
-// heartbeats using the event bus and broadcasts events to peers upon receiving
-// them.
-func (conR *ConsensusReactor) broadcastRoutine() error {
+// startBroadcastRoutine subscribes for new round steps, votes and proposal
+// heartbeats using the event bus and starts a go routine to broadcasts events
+// to peers upon receiving them.
+func (conR *ConsensusReactor) startBroadcastRoutine() error {
 	const subscriber = "consensus-reactor"
 	ctx := context.Background()
 

types/event_buffer.go

@@ -3,7 +3,7 @@ package types
 // Interface assertions
 var _ TxEventPublisher = (*TxEventBuffer)(nil)
 
-// TxEventBuffer is a buffer of events, which uses a slice to temporary store
+// TxEventBuffer is a buffer of events, which uses a slice to temporarily store
 // events.
 type TxEventBuffer struct {
 	next     TxEventPublisher
@@ -11,7 +11,7 @@ type TxEventBuffer struct {
 	events   []EventDataTx
 }
 
-// NewTxEventBuffer accepts an EventBus and returns a new buffer with the given
+// NewTxEventBuffer accepts a TxEventPublisher and returns a new buffer with the given
 // capacity.
 func NewTxEventBuffer(next TxEventPublisher, capacity int) *TxEventBuffer {
 	return &TxEventBuffer{

types/events.go

@@ -42,7 +42,7 @@ var (
 	EventDataNameTx                = "tx"
 	EventDataNameRoundState        = "round_state"
 	EventDataNameVote              = "vote"
-	EventDataNameProposalHeartbeat = "proposer_heartbeat"
+	EventDataNameProposalHeartbeat = "proposal_heartbeat"
 )
 
 // implements events.EventData