Increase timeout in TestSubscribeMultipleTimes

Increase delay to 10ms; makes go test -race happy.
This commit is contained in:
Raghav Gulati 2018-01-16 01:46:33 -08:00 committed by vyzo
parent 0ec8f2fa08
commit 99a4f9e5ed
2 changed files with 2 additions and 2 deletions

View File

@ -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() {

View File

@ -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"))