Method Schedule

library/cpp/neh/tcp2.cpp:1089–1100

            }

            THandleRef Schedule(const TMessage& msg, IOnRecv* fallback, TServiceStatRef& ss) {
                //find exist connection or create new
                TRequest::THandleRef hndl(new TRequest::THandle(fallback, msg, !ss ? nullptr : new TStatCollector(ss)));
                try {
                    TRequest::Run(hndl, msg, *this);
                } catch (...) {
                    hndl->ResetOnRecv();
                    hndl->ReleaseRequest();
                    throw;
                }
                return hndl.Get();
            }

            TExecutorsPool& ExecutorsPool() {
                return EP_;