Method Next

library/cpp/neh/rq.cpp:125–139

        }

        IRequestRef Next() override {
            IRequestRef ret;

            C_.Inc();
            while (!Q_.Dequeue(&ret)) {
                E_.Wait();
            }
            C_.Dec();

            if (Q_.Size() && C_.Val()) {
                E_.Signal();
            }

            return ret;
        }

    private:
        TEvent E_;