diff --git a/waku/v2/api/publish/message_check.go b/waku/v2/api/publish/message_check.go index ef5148bd..a7b16a57 100644 --- a/waku/v2/api/publish/message_check.go +++ b/waku/v2/api/publish/message_check.go @@ -125,8 +125,8 @@ func (m *MessageSentCheck) SetStorePeerID(peerID peer.ID) { m.storePeerID = peerID } -// CheckIfMessagesStored checks if the tracked outgoing messages are stored periodically -func (m *MessageSentCheck) CheckIfMessagesStored() { +// Start checks if the tracked outgoing messages are stored periodically +func (m *MessageSentCheck) Start() { ticker := time.NewTicker(m.hashQueryInterval) defer ticker.Stop() for {