public function handleDisconnect(ConnectionInterface $connection, LoggerInterface $logger)
    {
        $timers = $this->getTimers();
        if ($timers->contains($connection)) {
            $this->getLogger()->debug('Detaching activity listener for disconnected connection');
            $timers->offsetGet($connection)->cancel();
            $timers->detach($connection);
        }
    }