If a sample stream is already ded, just warn

incremental_update_paths
Tyler Goodlet 2022-04-22 14:06:48 -04:00
parent c94c53286b
commit af6aad4e9c
1 changed files with 6 additions and 1 deletions

View File

@ -168,7 +168,12 @@ async def broadcast(
log.error(
f'{stream._ctx.chan.uid} dropped connection'
)
try:
subs.remove(stream)
except ValueError:
log.warning(
f'{stream._ctx.chan.uid} sub already removed!?'
)
@tractor.context