connector
This commit is contained in:
parent
abadd34aeb
commit
ee1e191c53
@ -178,7 +178,9 @@ class Worker:
|
|||||||
async def pipe_get_msg(self, reader):
|
async def pipe_get_msg(self, reader):
|
||||||
while True:
|
while True:
|
||||||
try:
|
try:
|
||||||
|
self.log.critical("---1")
|
||||||
msg = await reader.readexactly(1)
|
msg = await reader.readexactly(1)
|
||||||
|
self.log.critical("---2")
|
||||||
if msg == b'M':
|
if msg == b'M':
|
||||||
msg = await reader.readexactly(1)
|
msg = await reader.readexactly(1)
|
||||||
if msg == b'E':
|
if msg == b'E':
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user