Method ExecAsync

library/cpp/par/par_util.h:45–54

    template <class TInputArg, class TOutputArg>
    class TMapReduceCmd: public IDistrCmd {
        void ExecAsync(IUserContext* ctx, int hostId, TVector<char>* params, IDCResultNotify* dcNotify, int reqId) const override {
            CHROMIUM_TRACE_FUNCTION();
            TInputArg inp;
            SerializeFromMem(params, inp);
            TOutputArg outp;
            DoMapEx(ctx, hostId, &inp, &outp, dcNotify);
            TVector<char> buf;
            SerializeToMem(&buf, outp);
            dcNotify->DistrCmdComplete(reqId, &buf);
        }
        void MergeAsync(TVector<TVector<char>>* src, IDCResultNotify* dcNotify, int reqId) const override {
            CHROMIUM_TRACE_FUNCTION();
            TVector<TOutputArg> srcData;