diff --git a/floodsub.go b/floodsub.go index 52a93b9..fc67d22 100644 --- a/floodsub.go +++ b/floodsub.go @@ -252,7 +252,7 @@ func (p *PubSub) announce(topic string, sub bool) { } } -// notifySubs sends a given message to all corresponding subscribbers. +// notifySubs sends a given message to all corresponding subscribers. // Only called from processLoop. func (p *PubSub) notifySubs(msg *pb.Message) { for _, topic := range msg.GetTopicIDs() { diff --git a/floodsub_test.go b/floodsub_test.go index 51ee0b8..28c1078 100644 --- a/floodsub_test.go +++ b/floodsub_test.go @@ -524,7 +524,7 @@ func TestSubscribeMultipleTimes(t *testing.T) { } // make sure subscribing is finished by the time we publish - time.Sleep(1 * time.Millisecond) + time.Sleep(10 * time.Millisecond) psubs[1].Publish("foo", []byte("bar"))