We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ad9020c commit 94e7389Copy full SHA for 94e7389
msgq/tests/test_messaging.py
@@ -52,9 +52,11 @@ def test_conflate(self):
52
recvd_msgs = msgq.drain_sock_raw(sub_sock)
53
if conflate:
54
assert len(recvd_msgs) == 1
55
+ assert recvd_msgs[0] == sent_msgs[-1]
56
else:
- # TODO: compare actual data
57
assert len(recvd_msgs) == len(sent_msgs)
58
+ for rec_msg, sent_msg in zip(recvd_msgs, sent_msgs):
59
+ assert rec_msg == sent_msg
60
61
def test_receive_timeout(self):
62
sock = random_sock()
0 commit comments