jc211
/
tractor
forked from goodboy/tractor
1
0
Fork 0
Code Pull Requests Activity

Speedup the dynamic pubsub test

bi_streaming
Tyler Goodlet 2021-06-13 20:26:01 -04:00
parent f2b1ef3fc9
commit 43ce533dbf
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/test_advanced_streaming.py
View File

@ -33,9 +33,9 @@ async def publisher(
for sub_stream in _registry[sub]:
await sub_stream.send(val)
# throttle send rate to ~4Hz
# throttle send rate to ~1kHz
# making it readable to a human user
await trio.sleep(1/4)
await trio.sleep(1/1000)
@tractor.context
@ -133,7 +133,7 @@ def test_dynamic_pub_sub():
)
# block until cancelled by user
with trio.fail_after(10):
with trio.fail_after(3):
await trio.sleep_forever()
try: