forked from goodboy/tractor
1
0
Fork 0

Avoid mutate during interate error

cf_backup
Tyler Goodlet 2021-06-30 13:52:31 -04:00
parent 4bd583786a
commit fd7a2d378a
1 changed files with 1 additions and 1 deletions

View File

@ -30,7 +30,7 @@ async def publisher(
sub = 'even' if is_even(val) else 'odd' sub = 'even' if is_even(val) else 'odd'
for sub_stream in _registry[sub]: for sub_stream in _registry[sub].copy():
await sub_stream.send(val) await sub_stream.send(val)
# throttle send rate to ~1kHz # throttle send rate to ~1kHz