Add is_running() method.

This commit is contained in:
Yuxin Wang 2018-10-10 20:34:15 -04:00
parent fbd2b1f699
commit 90b3871780

View file

@ -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