Skip to content

Commit d7b380b

Browse files
author
yijxie
committed
test code small fix
1 parent 92afd97 commit d7b380b

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

sdk/eventhub/azure-eventhubs/tests/livetest/synctests/test_receive.py

+2
Original file line numberDiff line numberDiff line change
@@ -62,6 +62,7 @@ def on_event(partition_context, event):
6262
on_event.event_position = None
6363
connection_str, senders = connstr_senders
6464
senders[0].send(EventData(b"Inclusive"))
65+
senders[1].send(EventData(b"Inclusive"))
6566
client = EventHubConsumerClient.from_connection_string(connection_str)
6667
with client:
6768
thread = threading.Thread(target=client.receive, args=(on_event, "$default"),
@@ -73,6 +74,7 @@ def on_event(partition_context, event):
7374
assert on_event.event_position is not None
7475
thread.join()
7576
senders[0].send(EventData(expected_result))
77+
senders[1].send(EventData(expected_result))
7678
client2 = EventHubConsumerClient.from_connection_string(connection_str)
7779
with client2:
7880
thread = threading.Thread(target=client2.receive, args=(on_event, "$default"),

0 commit comments

Comments
 (0)