Method OnReceiveMessage

library/cpp/neh/tcp2.cpp:996–1013

must be called only from asio thread

                //must be called only from asio thread
                void OnReceiveMessage() {
                    //DBGOUT("OnReceiveMessage");
                    const TBaseHeader& hdr = Msg_.BaseHeader();

                    if (hdr.Type == TBaseHeader::Response) {
                        ProcessReqsInFlyQueue();
                        TReqsInFly::iterator it = ReqsInFly_.find(hdr.Id);
                        if (it == ReqsInFly_.end()) {
                            DBGOUT("ignore response: " << hdr.Id);
                            return;
                        }

                        it->second->OnResponse(Msg_);
                        ReqsInFly_.erase(it);
                    } else {
                        throw yexception() << TStringBuf("unsupported message type: ") << hdr.Type;
                    }
                }

                TRequestId LastSendedRequestId() const noexcept {
                    return LastSendedReqId_.load(std::memory_order_acquire);