Struct MessageRouter

p2pserver/message/utils/msg_router.go:37–43

MessageRouter mostly route different message type-based to the related message handler

// MessageRouter mostly route different message type-based to the
// related message handler
type MessageRouter struct {
	msgHandlers map[string]MessageHandler // Msg handler mapped to msg type
	RecvChan    chan *types.MsgPayload    // The channel to handle sync msg
	stopRecvCh  chan bool                 // To stop sync channel
	p2p         p2p.P2P                   // Refer to the p2p network
	pid         *actor.PID                // P2P actor
}

// NewMsgRouter returns a message router object
func NewMsgRouter(p2p p2p.P2P) *MessageRouter {