docs: async def subscribe(self, endpoints: list, handler):
          """
          Subscribe to a list of endpoints
          :param endpoints: List of endpoints the subscribers is interested to subscribe to
          :type endpoints: list
          :param handler: The callback to call when a particular event is published.
                          Must take two arguments, a channel to which the event was published
                          and the payload.
          :return:
          """
          connection = await self._get_conn()
          subscriber = await connection.start_subscribe()
          await subscriber.subscribe(endpoints)
          while True:
              payload = await subscriber.next_published()
              handler(payload.channel, payload.value)