Shield channel closing in `_connect_chan()`
parent
0d4d461c41
commit
cc6b2d4057
|
@ -716,4 +716,5 @@ async def _connect_chan(
|
||||||
chan = Channel((host, port))
|
chan = Channel((host, port))
|
||||||
await chan.connect()
|
await chan.connect()
|
||||||
yield chan
|
yield chan
|
||||||
await chan.aclose()
|
with trio.CancelScope(shield=True):
|
||||||
|
await chan.aclose()
|
||||||
|
|
Loading…
Reference in New Issue