Method Next

library/cpp/neh/rq.cpp:163–174

        }

        IRequestRef Next() override {
            TGuard<TMutex> g(M_);

            while (Q_.empty()) {
                C_.Wait(M_);
            }

            IRequestRef ret = *Q_.begin();
            Q_.pop_front();

            return ret;
        }

    private:
        TDeque<IRequestRef> Q_;