Skip to content

Commit

Permalink
fix test
Browse files Browse the repository at this point in the history
  • Loading branch information
blink1073 committed Dec 23, 2023
1 parent 259ec3d commit 2bca5d2
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions tests/test_zmqstream.py
Original file line number Diff line number Diff line change
Expand Up @@ -36,8 +36,8 @@ def on_recv1(msg):

stream1.on_recv(on_recv1)
stream2.send(b"ping")
msg = await future1
assert msg == b"ping"
msg_list = await future1
assert msg_list == [b"ping"]
future2 = Future()
future3 = Future()

Expand All @@ -52,8 +52,8 @@ def on_recv2(msg):
stream1.send(b"pong")
await future2

msg = await future3
assert msg == b"pong"
msg_list = await future3
assert msg_list == [b"pong"]
stream1.close()
stream2.close()
context.term()

0 comments on commit 2bca5d2

Please sign in to comment.