diff --git a/tfw/components/pipe_io/pipe_connector/pipe_connector.py b/tfw/components/pipe_io/pipe_connector/pipe_connector.py index 06ba4ab..6f76e0e 100644 --- a/tfw/components/pipe_io/pipe_connector/pipe_connector.py +++ b/tfw/components/pipe_io/pipe_connector/pipe_connector.py @@ -15,12 +15,12 @@ class PipeConnector: def __init__(self, path): self.recv_pipes, self.send_pipes = {}, {} - self.observer = self.build_observer(path) + self.observer = self._build_observer(path) self.observer.on_any_event = self._on_any_event self.observer.start() self._connect_existing_pipes(path) - def build_observer(self, path): # pylint: disable=no-self-use + def _build_observer(self, path): # pylint: disable=no-self-use if not exists(path): mkdir(path) if not access(path, R_OK): diff --git a/tfw/components/pipe_io/pipe_connector/test_proxy_pipe_connector.py b/tfw/components/pipe_io/pipe_connector/test_proxy_pipe_connector.py index e49f7cc..989c5bf 100644 --- a/tfw/components/pipe_io/pipe_connector/test_proxy_pipe_connector.py +++ b/tfw/components/pipe_io/pipe_connector/test_proxy_pipe_connector.py @@ -43,7 +43,7 @@ class MockPipeConnector(ProxyPipeConnector): self.reader_events, self.writer_events = [], [] super().__init__(path, connector) - def build_observer(self, path): + def _build_observer(self, path): return MockObserver() def build_reader(self, path):