Method ProcessReqsInFlyQueue

library/cpp/neh/tcp2.cpp:704–716

must be called only from asio thread

                //must be called only from asio thread
                void ProcessReqsInFlyQueue() {
                    if (AtomicGet(State_) == Closed) {
                        return;
                    }

                    TRequest* reqPtr;

                    while (ReqsInFlyQueue_.Dequeue(&reqPtr)) {
                        TRequestRef reqTmp(reqPtr);
                        reqPtr->UnRef();
                        ReqsInFly_[reqPtr->ReqId()].Swap(reqTmp);
                    }
                }

                //must be called only from asio thread
                void OnConnect(const TErrorCode& ec, IHandlingContext&) {