diff --git a/transport_tcp.py b/transport_tcp.py index 875a0e7..8a10d0b 100644 --- a/transport_tcp.py +++ b/transport_tcp.py @@ -53,11 +53,8 @@ class TCPTransport: async def _alive_loop(self): try: while True: - if self.writer: - #logger.debug("Send alive", int(time() - self.socket_start)) - self.writer.write(b"0") - await self.writer.drain() - await asyncio.sleep(1) + await self.send(b"0") + await asyncio.sleep(1) except asyncio.CancelledError: pass except: