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

Speedup the dynamic pubsub test

bistream_backup
Tyler Goodlet 2021-06-13 20:26:01 -04:00
parent c542b915d6
commit ae45b5ff1d
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]: for sub_stream in _registry[sub]:
await sub_stream.send(val) await sub_stream.send(val)
# throttle send rate to ~4Hz # throttle send rate to ~1kHz
# making it readable to a human user # making it readable to a human user
await trio.sleep(1/4) await trio.sleep(1/1000)
@tractor.context @tractor.context
@ -133,7 +133,7 @@ def test_dynamic_pub_sub():
) )
# block until cancelled by user # block until cancelled by user
with trio.fail_after(10): with trio.fail_after(3):
await trio.sleep_forever() await trio.sleep_forever()
try: try: