Avoid mutate during interate error

bi_streaming
Tyler Goodlet 2021-06-30 13:52:31 -04:00
parent 8371621e57
commit e1533d35dc
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