logos-messaging/go-libp2p-pubsub
1
0
Fork 0
mirror of https://github.com/logos-messaging/go-libp2p-pubsub.git synced 2026-01-04 05:43:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

Return false when we haven't subscribed to anything

Browse Source
This commit is contained in:
Garrett Thornburg 2017-09-01 21:16:41 -04:00
parent b93dd9968a
commit 63c977c815
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
floodsub.go
View File

@ -259,6 +259,10 @@ func (p *PubSub) markSeen(id string) {
// subscribedToMessage returns whether we are subscribed to one of the topics // subscribedToMessage returns whether we are subscribed to one of the topics
// of a given message // of a given message
func (p *PubSub) subscribedToMsg(msg *pb.Message) bool { func (p *PubSub) subscribedToMsg(msg *pb.Message) bool {
if len(p.myTopics) == 0 {
return false
}
for _, t := range msg.GetTopicIDs() { for _, t := range msg.GetTopicIDs() {
if _, ok := p.myTopics[t]; ok { if _, ok := p.myTopics[t]; ok {
return true return true