Skip to content
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
small fix in samples
  • Loading branch information
yunhaoling committed Nov 5, 2019
commit fce1b175eda924e3da58299974dd55344c3da2b5
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ async def receive(client):
partition_id='0',
track_last_enqueued_event_properties=True)
except KeyboardInterrupt:
client.close()
await client.close()


async def main():
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ async def receive(client):
# With specified partition_id, load-balance will be disabled
# await client.receive(event_handler=event_handler, consumer_group="$default", partition_id = '0'))
except KeyboardInterrupt:
client.close()
await client.close()


async def main():
Expand Down