def _client_registered(self, channel, client, cmd):
        return (client.connection._sock is not None and
                (channel, client, cmd) in self._chan_to_sock)
dataset/ETHPy150Open celery/kombu/kombu/transport/redis.py/MultiChannelPoller._client_registered/original