Don't clobber msg loop mem chan...
parent
7e2a054dd7
commit
186968d3e7
|
@ -332,12 +332,6 @@ class Portal:
|
||||||
# message right now since there shouldn't be a reason to
|
# message right now since there shouldn't be a reason to
|
||||||
# stop and restart the stream, right?
|
# stop and restart the stream, right?
|
||||||
try:
|
try:
|
||||||
|
|
||||||
# We are for sure done with this stream and no more
|
|
||||||
# messages are expected to be delivered from the
|
|
||||||
# runtime's msg loop.
|
|
||||||
await recv_chan.aclose()
|
|
||||||
|
|
||||||
await ctx.cancel()
|
await ctx.cancel()
|
||||||
|
|
||||||
except trio.ClosedResourceError:
|
except trio.ClosedResourceError:
|
||||||
|
|
Loading…
Reference in New Issue