Skip to content

GitLab

Commit 13e0a4dc authored by hannahhoward's avatar hannahhoward
Browse files
Options

fix(messagequeue): test correction 

timing on test was failure prone, corrected
parent 256e680c
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
messagequeue/messagequeue_test.go
View file @ 13e0a4dc
...@@ -180,9 +180,9 @@ func TestWantlistRebroadcast(t *testing.T) { ...@@ -180,9 +180,9 @@ func TestWantlistRebroadcast(t *testing.T) {
} }
messageQueue.SetRebroadcastInterval(5 * time.Millisecond) messageQueue.SetRebroadcastInterval(5 * time.Millisecond)
messages = collectMessages(ctx, t, messagesSent, 10*time.Millisecond) messages = collectMessages(ctx, t, messagesSent, 8*time.Millisecond)
if len(messages) != 1 { if len(messages) != 1 {
t.Fatal("wrong number of messages were sent for initial wants") t.Fatal("wrong number of messages were rebroadcast")
} }
firstMessage := messages[0] firstMessage := messages[0]
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment