Method Next

library/cpp/neh/rq.cpp:44–64

        }

        IRequestRef Next() override {
            IRequestRef ret;

#if 0
            for (size_t i = 0; i < 20; ++i) {
                if (Q_.Dequeue(&ret)) {
                    return ret;
                }

                //asm volatile ("pause;");
            }
#endif

            while (!Q_.Dequeue(&ret)) {
                char ch;

                R_.Read(&ch, 1);
            }

            return ret;
        }

    private:
        TPipeHandle R_;