def METHOD_NAME(self, ex):
    _logger.info('Lost connection from %s, %s', self.peer_name, ex)
    self.transport.close()
    self.iserver.asyncio_transports.remove(self.transport)
    closing_task = asyncio.create_task(self.processor.close())
    self.closing_tasks.append(closing_task)
    if self in self.clients:
        self.clients.remove(self)
    self.messages.put_nowait((None, None))
    self._task.cancel()