#include "LibLsp/JsonRpc/threaded_queue.h"

// static
bool MultiQueueWaiter::HasState(std::initializer_list<BaseThreadQueue*> queues)
{
    for (BaseThreadQueue* queue : queues)
    {
        if (!queue->IsEmpty())
        {
            return true;
        }
    }
    return false;
}

bool MultiQueueWaiter::ValidateWaiter(std::initializer_list<BaseThreadQueue*> queues)
{
    for (BaseThreadQueue* queue : queues)
    {
        if (queue->waiter.get() != this)
        {
            return false;
        }
    }
    return true;
}