def monitor_subscriptions
        response = _conn.get('/subscriptions')
        raise ConnectionError, "failed to list subscribers (status: #{response.status})" unless response.success?

        Oj.load(response.body).map do |raw_subscription|