Drop needless if check
parent
1da69b1396
commit
f7706074a2
|
@ -282,10 +282,8 @@ class Actor:
|
||||||
if msg is None: # terminate sentinel
|
if msg is None: # terminate sentinel
|
||||||
log.debug(
|
log.debug(
|
||||||
f"Cancelling all tasks for {chan} from {chan.uid}")
|
f"Cancelling all tasks for {chan} from {chan.uid}")
|
||||||
scopes = self._rpc_tasks.pop(chan, None)
|
for scope, func in self._rpc_tasks.pop(chan, ()):
|
||||||
if scopes:
|
scope.cancel()
|
||||||
for scope, func in scopes:
|
|
||||||
scope.cancel()
|
|
||||||
|
|
||||||
log.debug(
|
log.debug(
|
||||||
f"Msg loop signalled to terminate for"
|
f"Msg loop signalled to terminate for"
|
||||||
|
|
Loading…
Reference in New Issue