XPub [64]byte
}
-//NewBlockProposeEvent block propose event which needs to broadcast.
-type NewBlockProposeEvent struct{ Block types.Block }
-
// TypeMuxEvent is a time-tagged notification pushed to subscribers.
type TypeMuxEvent struct {
Time time.Time
}
func (m *Manager) blockProposeMsgBroadcastLoop() {
- blockProposeMsgSub, err := m.eventDispatcher.Subscribe(event.NewBlockProposeEvent{})
+ blockProposeMsgSub, err := m.eventDispatcher.Subscribe(event.NewProposedBlockEvent{})
if err != nil {
logrus.WithFields(logrus.Fields{"module": logModule, "err": err}).Error("failed on subscribe NewBlockProposeEvent")
return
return
}
- ev, ok := obj.Data.(event.NewBlockProposeEvent)
+ ev, ok := obj.Data.(event.NewProposedBlockEvent)
if !ok {
logrus.WithFields(logrus.Fields{"module": logModule}).Error("event type error")
continue