Method MergeAsync

library/cpp/par/par_util.h:55–67

            dcNotify->DistrCmdComplete(reqId, &buf);
        }
        void MergeAsync(TVector<TVector<char>>* src, IDCResultNotify* dcNotify, int reqId) const override {
            CHROMIUM_TRACE_FUNCTION();
            TVector<TOutputArg> srcData;
            int count = src->ysize();
            srcData.resize(count);
            for (int i = 0; i < count; ++i)
                SerializeFromMem(&(*src)[i], srcData[i]);
            TOutputArg outp;
            DoReduce(&srcData, &outp);
            TVector<char> buf;
            SerializeToMem(&buf, outp);
            dcNotify->DistrCmdComplete(reqId, &buf);
        }

    public:
        using TInput = TInputArg;