Method TNetlibaRequester

library/cpp/par/par_network.cpp:365–381

    class TNetlibaRequester: public IRequester {
    public:
        explicit TNetlibaRequester(
            int listenPort,
            TProcessQueryCancelCallback queryCancelCallback,
            TProcessQueryCallback queryCallback,
            TProcessReplyCallback replyCallback)
            : QueryCancelCallback(std::move(queryCancelCallback))
            , QueryCallback(std::move(queryCallback))
            , ReplyCallback(std::move(replyCallback))
            , Requester(NNetliba_v12::CreateHttpUdpRequester(listenPort))
        {
            PAR_DEBUG_LOG << "Created netliba httpudp requester on port " << listenPort << Endl;
            Requester->EnableReportRequestCancel();

            ReceiverThread = SystemThreadFactory()->Run([this]() {
                ReceiveLoopFunc();
            });
        }
        ~TNetlibaRequester() override {
            Stopped = true;
            Requester->GetAsyncEvent().Signal();