code: def execute_pubsub(self, command, *channels):
          
          conn, address = self.get_connection(command)
          if conn is not None:
              return conn.execute_pubsub(command, *channels)
          else:
              return self._wait_execute_pubsub(address, command, channels, {})
docs: Executes Redis (p)subscribe/(p)unsubscribe commands.
  
          ConnectionsPool picks separate connection for pub/sub
          and uses it until explicitly closed or disconnected
          (unsubscribing from all channels/patterns will leave connection
           locked for pub/sub use).
  
          There is no auto-reconnect for this PUB/SUB connection.
  
          Returns asyncio.gather coroutine waiting for all channels/patterns
          to receive answers.