Skip to content

Commit 9aee519

Browse files
committed
FIX: p2p tests
1 parent 3b7044b commit 9aee519

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

ClientUnitTests/SendReceiveTests.cs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -138,10 +138,11 @@ public void TestP2P()
138138
[Test]
139139
public void TestSendDuration()
140140
{
141-
Task listener = Task.Run(() => {
141+
Task receiver = Task.Run(() => {
142142
Assert.AreEqual(0, this.clientRunner.RunReceiver("--address duration_queue --count 5"));
143143
});
144144
Assert.AreEqual(0, this.clientRunner.RunSender("--address duration_queue --count 5 --msg-content string_message --duration 5"));
145+
Task.WaitAll(receiver);
145146
}
146147

147148
[Test]
@@ -169,10 +170,11 @@ public void TestRejectMessages()
169170
[Test]
170171
public void TestSendReceiveTimeout()
171172
{
172-
Task listener = Task.Run(() => {
173+
Task timeoutReceiver = Task.Run(() => {
173174
Assert.AreEqual(0, this.clientRunner.RunReceiver("--address timeout_queue --count 5 --timeout 10"));
174175
});
175176
Assert.AreEqual(0, this.clientRunner.RunSender("--address timeout_queue --count 5 --timeout 5"));
177+
Task.WaitAll(timeoutReceiver);
176178
}
177179
}
178180
}

0 commit comments

Comments
 (0)