diff --git a/p2pfs/core/server.py b/p2pfs/core/server.py index dd1d82d..0fe9d48 100644 --- a/p2pfs/core/server.py +++ b/p2pfs/core/server.py @@ -41,6 +41,9 @@ class MessageServer: self._compressor = zstd.ZstdCompressor() self._decompressor = zstd.ZstdDecompressor() + def is_running(self): + return self._is_running + async def start(self, local_address, loop=None): logger.info('Start listening on {}'.format(self._server_address)) # start server