diff --git a/lib/tfw/components/pipe_io_event_handler.py b/lib/tfw/components/pipe_io_event_handler.py index 04cb634..ef162c9 100644 --- a/lib/tfw/components/pipe_io_event_handler.py +++ b/lib/tfw/components/pipe_io_event_handler.py @@ -21,7 +21,7 @@ class PipeIOEventHandlerBase(EventHandlerBase): self.pipe_io.start() @abstractmethod - def handle_pipe_event(self, message): + def handle_pipe_event(self, message_bytes): raise NotImplementedError() def cleanup(self): @@ -42,6 +42,6 @@ class PipeIOEventHandler(PipeIOEventHandlerBase): json_bytes = dumps(message).encode() self.pipe_io.send_message(json_bytes) - def handle_pipe_event(self, message): - json = loads(message) + def handle_pipe_event(self, message_bytes): + json = loads(message_bytes) self.server_connector.send(json)