parent
92320c8922
commit
aaf2257117
@ -160,7 +160,7 @@ class PipeClient():
|
|||||||
|
|
||||||
def _write_pipe_open(self) -> None:
|
def _write_pipe_open(self) -> None:
|
||||||
"""Open _write_pipe."""
|
"""Open _write_pipe."""
|
||||||
self._write_pipe = open(WRITE_NAME, 'w', encoding='ascii')
|
self._write_pipe = open(WRITE_NAME, 'w')
|
||||||
|
|
||||||
def _read_thread_start(self) -> None:
|
def _read_thread_start(self) -> None:
|
||||||
"""Start read_pipe thread."""
|
"""Start read_pipe thread."""
|
||||||
@ -204,7 +204,7 @@ class PipeClient():
|
|||||||
"""Read FIFO in worker thread."""
|
"""Read FIFO in worker thread."""
|
||||||
# Thread will wait at this read until it connects.
|
# Thread will wait at this read until it connects.
|
||||||
# Connection should occur as soon as _write_pipe has connected.
|
# Connection should occur as soon as _write_pipe has connected.
|
||||||
with open(READ_NAME, 'r', encoding='ascii') as read_pipe:
|
with open(READ_NAME, 'r') as read_pipe:
|
||||||
message = ''
|
message = ''
|
||||||
pipe_ok = True
|
pipe_ok = True
|
||||||
while pipe_ok:
|
while pipe_ok:
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user