File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -20,10 +20,10 @@ class TcpIo(AdapterIo[CommandAdapter]):
2020 host : str
2121 port : int
2222
23- def __init__ (self , host : str , port : int , separator : str | None = None ) -> None :
23+ def __init__ (self , host : str , port : int , terminator : str | None = None ) -> None :
2424 self .host = host
2525 self .port = port
26- self .separator = separator
26+ self .terminator = terminator
2727
2828 async def setup (
2929 self , adapter : CommandAdapter , raise_interrupt : RaiseInterrupt
@@ -80,9 +80,9 @@ async def reply(replies: AsyncIterable[Optional[bytes]]) -> None:
8080 tasks .append (asyncio .create_task (reply (on_connect ())))
8181
8282 while True :
83- if self .separator is not None :
83+ if self .terminator is not None :
8484 data : bytes = (
85- await reader .readuntil (separator = self .separator .encode ())
85+ await reader .readuntil (separator = self .terminator .encode ())
8686 )
8787 else :
8888 data : bytes = await reader .read (1024 )
You can’t perform that action at this time.
0 commit comments