connector
This commit is contained in:
parent
a1444c0975
commit
0105a3681c
@ -253,9 +253,7 @@ 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