code: def subscribe(self, channel, *channels):
          
          conn = self._pool_or_conn
          return wait_return_channels(
              conn.execute_pubsub(b'SUBSCRIBE', channel, *channels),
              conn, 'pubsub_channels')
docs: Switch connection to Pub/Sub mode and
          subscribe to specified channels.
  
          Arguments can be instances of :class:`~aioredis.Channel`.
  
          Returns :func:`asyncio.gather()` coroutine which when done will return
          a list of :class:`~aioredis.Channel` objects.