Versions in this module Expand all Collapse all v0 v0.0.1 Sep 5, 2023 Changes in this version + func RunTest(peers []p2p.Messenger, testIndex int, topic string) bool + type MessageProcesssor struct + RequiredValue []byte + func NewMessageProcessor(chanDone chan struct{}, requiredVal []byte) *MessageProcesssor + func (mp *MessageProcesssor) IsInterfaceNil() bool + func (mp *MessageProcesssor) ProcessReceivedMessage(message p2p.MessageP2P, _ core.PeerID) error + func (mp *MessageProcesssor) WasDataReceived() bool + type SimpleMessageProcessor struct + func (smp *SimpleMessageProcessor) GetLastMessage() []byte + func (smp *SimpleMessageProcessor) IsInterfaceNil() bool + func (smp *SimpleMessageProcessor) ProcessReceivedMessage(message p2p.MessageP2P, _ core.PeerID) error
Go to main page