Add strong close consistency guarantee to reader side

This commit is contained in:
Kristóf Tóth 2019-05-04 22:34:28 +02:00
parent 9ccb05a709
commit 14ac1b82d1

View File

@ -25,8 +25,7 @@ class PipeReaderThread(Thread):
self._stop_event.set() self._stop_event.set()
break break
if message == self.eof: if message == self.eof:
pipe.close() self._open().close()
pipe = self._open()
continue continue
self._message_handler(message[:-1]) self._message_handler(message[:-1])