Skip to content

Commit f7705b4

Browse files
committed
tweaked examples
1 parent 406eb98 commit f7705b4

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

examples/simple_async_subscriber.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ async def main(host: str = "127.0.0.1", port: int = 12345) -> None:
1414
while True:
1515
async with sub.recv_zero_copy() as msg:
1616
# Uncomment if you want to witness backpressure!
17-
# await asyncio.sleep(0.15)
17+
# await asyncio.sleep(1.0)
1818
print(msg)
1919
except asyncio.CancelledError:
2020
pass

examples/simple_subscriber.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ def main(host: str = "127.0.0.1", port: int = 12345) -> None:
1010

1111
def on_message(msg: str) -> None:
1212
# Uncomment if you want to witness backpressure!
13-
time.sleep(1.0)
13+
# time.sleep(1.0)
1414
print(msg)
1515

1616
ctx.create_subscription(TOPIC, callback=on_message)

0 commit comments

Comments
 (0)