jc211
/
tractor
forked from goodboy/tractor
1
0
Fork 0
Code Pull Requests Activity

Detail out EoC-by-self log msg

runtime_to_msgspec
Tyler Goodlet 2024-04-07 16:35:00 -04:00
parent aea5abdd70
commit 38111e8d53
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
tractor/_streaming.py
View File

@ -46,7 +46,6 @@ from .trionics import (
from tractor.msg import ( from tractor.msg import (
Stop, Stop,
Yield, Yield,
Error,
) )
if TYPE_CHECKING: if TYPE_CHECKING:
@ -391,11 +390,11 @@ class MsgStream(trio.abc.Channel):
if not self._eoc: if not self._eoc:
log.cancel( log.cancel(
'Stream closed before it received an EoC?\n' 'Stream closed by self before it received an EoC?\n'
'Setting eoc manually..\n..' 'Setting eoc manually..\n..'
) )
self._eoc: bool = trio.EndOfChannel( self._eoc: bool = trio.EndOfChannel(
f'Context stream closed by {self._ctx.side}\n' f'Context stream closed by self({self._ctx.side})\n'
f'|_{self}\n' f'|_{self}\n'
) )
# ?XXX WAIT, why do we not close the local mem chan `._rx_chan` XXX? # ?XXX WAIT, why do we not close the local mem chan `._rx_chan` XXX?