2 Star 7 Fork 0

tencentcloud/tencentcloud-sdk-cpp

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
TrtcClient.cpp 92.58 KB
一键复制 编辑 原始数据 按行查看 历史
tencentcloud 提交于 14天前 . release 3.1.18
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665
/*
* Copyright (c) 2017-2019 THL A29 Limited, a Tencent company. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#include <tencentcloud/trtc/v20190722/TrtcClient.h>
#include <tencentcloud/core/Executor.h>
#include <tencentcloud/core/Runnable.h>
using namespace TencentCloud;
using namespace TencentCloud::Trtc::V20190722;
using namespace TencentCloud::Trtc::V20190722::Model;
using namespace std;
namespace
{
const string VERSION = "2019-07-22";
const string ENDPOINT = "trtc.tencentcloudapi.com";
}
TrtcClient::TrtcClient(const Credential &credential, const string &region) :
TrtcClient(credential, region, ClientProfile())
{
}
TrtcClient::TrtcClient(const Credential &credential, const string &region, const ClientProfile &profile) :
AbstractClient(ENDPOINT, VERSION, credential, region, profile)
{
}
TrtcClient::ControlAIConversationOutcome TrtcClient::ControlAIConversation(const ControlAIConversationRequest &request)
{
auto outcome = MakeRequest(request, "ControlAIConversation");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
ControlAIConversationResponse rsp = ControlAIConversationResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return ControlAIConversationOutcome(rsp);
else
return ControlAIConversationOutcome(o.GetError());
}
else
{
return ControlAIConversationOutcome(outcome.GetError());
}
}
void TrtcClient::ControlAIConversationAsync(const ControlAIConversationRequest& request, const ControlAIConversationAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->ControlAIConversation(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::ControlAIConversationOutcomeCallable TrtcClient::ControlAIConversationCallable(const ControlAIConversationRequest &request)
{
auto task = std::make_shared<std::packaged_task<ControlAIConversationOutcome()>>(
[this, request]()
{
return this->ControlAIConversation(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::CreateBasicModerationOutcome TrtcClient::CreateBasicModeration(const CreateBasicModerationRequest &request)
{
auto outcome = MakeRequest(request, "CreateBasicModeration");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
CreateBasicModerationResponse rsp = CreateBasicModerationResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return CreateBasicModerationOutcome(rsp);
else
return CreateBasicModerationOutcome(o.GetError());
}
else
{
return CreateBasicModerationOutcome(outcome.GetError());
}
}
void TrtcClient::CreateBasicModerationAsync(const CreateBasicModerationRequest& request, const CreateBasicModerationAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->CreateBasicModeration(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::CreateBasicModerationOutcomeCallable TrtcClient::CreateBasicModerationCallable(const CreateBasicModerationRequest &request)
{
auto task = std::make_shared<std::packaged_task<CreateBasicModerationOutcome()>>(
[this, request]()
{
return this->CreateBasicModeration(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::CreateCloudRecordingOutcome TrtcClient::CreateCloudRecording(const CreateCloudRecordingRequest &request)
{
auto outcome = MakeRequest(request, "CreateCloudRecording");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
CreateCloudRecordingResponse rsp = CreateCloudRecordingResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return CreateCloudRecordingOutcome(rsp);
else
return CreateCloudRecordingOutcome(o.GetError());
}
else
{
return CreateCloudRecordingOutcome(outcome.GetError());
}
}
void TrtcClient::CreateCloudRecordingAsync(const CreateCloudRecordingRequest& request, const CreateCloudRecordingAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->CreateCloudRecording(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::CreateCloudRecordingOutcomeCallable TrtcClient::CreateCloudRecordingCallable(const CreateCloudRecordingRequest &request)
{
auto task = std::make_shared<std::packaged_task<CreateCloudRecordingOutcome()>>(
[this, request]()
{
return this->CreateCloudRecording(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::CreatePictureOutcome TrtcClient::CreatePicture(const CreatePictureRequest &request)
{
auto outcome = MakeRequest(request, "CreatePicture");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
CreatePictureResponse rsp = CreatePictureResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return CreatePictureOutcome(rsp);
else
return CreatePictureOutcome(o.GetError());
}
else
{
return CreatePictureOutcome(outcome.GetError());
}
}
void TrtcClient::CreatePictureAsync(const CreatePictureRequest& request, const CreatePictureAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->CreatePicture(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::CreatePictureOutcomeCallable TrtcClient::CreatePictureCallable(const CreatePictureRequest &request)
{
auto task = std::make_shared<std::packaged_task<CreatePictureOutcome()>>(
[this, request]()
{
return this->CreatePicture(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DeleteBasicModerationOutcome TrtcClient::DeleteBasicModeration(const DeleteBasicModerationRequest &request)
{
auto outcome = MakeRequest(request, "DeleteBasicModeration");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DeleteBasicModerationResponse rsp = DeleteBasicModerationResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DeleteBasicModerationOutcome(rsp);
else
return DeleteBasicModerationOutcome(o.GetError());
}
else
{
return DeleteBasicModerationOutcome(outcome.GetError());
}
}
void TrtcClient::DeleteBasicModerationAsync(const DeleteBasicModerationRequest& request, const DeleteBasicModerationAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DeleteBasicModeration(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DeleteBasicModerationOutcomeCallable TrtcClient::DeleteBasicModerationCallable(const DeleteBasicModerationRequest &request)
{
auto task = std::make_shared<std::packaged_task<DeleteBasicModerationOutcome()>>(
[this, request]()
{
return this->DeleteBasicModeration(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DeleteCloudRecordingOutcome TrtcClient::DeleteCloudRecording(const DeleteCloudRecordingRequest &request)
{
auto outcome = MakeRequest(request, "DeleteCloudRecording");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DeleteCloudRecordingResponse rsp = DeleteCloudRecordingResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DeleteCloudRecordingOutcome(rsp);
else
return DeleteCloudRecordingOutcome(o.GetError());
}
else
{
return DeleteCloudRecordingOutcome(outcome.GetError());
}
}
void TrtcClient::DeleteCloudRecordingAsync(const DeleteCloudRecordingRequest& request, const DeleteCloudRecordingAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DeleteCloudRecording(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DeleteCloudRecordingOutcomeCallable TrtcClient::DeleteCloudRecordingCallable(const DeleteCloudRecordingRequest &request)
{
auto task = std::make_shared<std::packaged_task<DeleteCloudRecordingOutcome()>>(
[this, request]()
{
return this->DeleteCloudRecording(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DeletePictureOutcome TrtcClient::DeletePicture(const DeletePictureRequest &request)
{
auto outcome = MakeRequest(request, "DeletePicture");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DeletePictureResponse rsp = DeletePictureResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DeletePictureOutcome(rsp);
else
return DeletePictureOutcome(o.GetError());
}
else
{
return DeletePictureOutcome(outcome.GetError());
}
}
void TrtcClient::DeletePictureAsync(const DeletePictureRequest& request, const DeletePictureAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DeletePicture(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DeletePictureOutcomeCallable TrtcClient::DeletePictureCallable(const DeletePictureRequest &request)
{
auto task = std::make_shared<std::packaged_task<DeletePictureOutcome()>>(
[this, request]()
{
return this->DeletePicture(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DeleteVoicePrintOutcome TrtcClient::DeleteVoicePrint(const DeleteVoicePrintRequest &request)
{
auto outcome = MakeRequest(request, "DeleteVoicePrint");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DeleteVoicePrintResponse rsp = DeleteVoicePrintResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DeleteVoicePrintOutcome(rsp);
else
return DeleteVoicePrintOutcome(o.GetError());
}
else
{
return DeleteVoicePrintOutcome(outcome.GetError());
}
}
void TrtcClient::DeleteVoicePrintAsync(const DeleteVoicePrintRequest& request, const DeleteVoicePrintAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DeleteVoicePrint(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DeleteVoicePrintOutcomeCallable TrtcClient::DeleteVoicePrintCallable(const DeleteVoicePrintRequest &request)
{
auto task = std::make_shared<std::packaged_task<DeleteVoicePrintOutcome()>>(
[this, request]()
{
return this->DeleteVoicePrint(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeAIConversationOutcome TrtcClient::DescribeAIConversation(const DescribeAIConversationRequest &request)
{
auto outcome = MakeRequest(request, "DescribeAIConversation");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeAIConversationResponse rsp = DescribeAIConversationResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeAIConversationOutcome(rsp);
else
return DescribeAIConversationOutcome(o.GetError());
}
else
{
return DescribeAIConversationOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeAIConversationAsync(const DescribeAIConversationRequest& request, const DescribeAIConversationAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeAIConversation(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeAIConversationOutcomeCallable TrtcClient::DescribeAIConversationCallable(const DescribeAIConversationRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeAIConversationOutcome()>>(
[this, request]()
{
return this->DescribeAIConversation(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeAITranscriptionOutcome TrtcClient::DescribeAITranscription(const DescribeAITranscriptionRequest &request)
{
auto outcome = MakeRequest(request, "DescribeAITranscription");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeAITranscriptionResponse rsp = DescribeAITranscriptionResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeAITranscriptionOutcome(rsp);
else
return DescribeAITranscriptionOutcome(o.GetError());
}
else
{
return DescribeAITranscriptionOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeAITranscriptionAsync(const DescribeAITranscriptionRequest& request, const DescribeAITranscriptionAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeAITranscription(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeAITranscriptionOutcomeCallable TrtcClient::DescribeAITranscriptionCallable(const DescribeAITranscriptionRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeAITranscriptionOutcome()>>(
[this, request]()
{
return this->DescribeAITranscription(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeCallDetailInfoOutcome TrtcClient::DescribeCallDetailInfo(const DescribeCallDetailInfoRequest &request)
{
auto outcome = MakeRequest(request, "DescribeCallDetailInfo");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeCallDetailInfoResponse rsp = DescribeCallDetailInfoResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeCallDetailInfoOutcome(rsp);
else
return DescribeCallDetailInfoOutcome(o.GetError());
}
else
{
return DescribeCallDetailInfoOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeCallDetailInfoAsync(const DescribeCallDetailInfoRequest& request, const DescribeCallDetailInfoAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeCallDetailInfo(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeCallDetailInfoOutcomeCallable TrtcClient::DescribeCallDetailInfoCallable(const DescribeCallDetailInfoRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeCallDetailInfoOutcome()>>(
[this, request]()
{
return this->DescribeCallDetailInfo(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeCloudRecordingOutcome TrtcClient::DescribeCloudRecording(const DescribeCloudRecordingRequest &request)
{
auto outcome = MakeRequest(request, "DescribeCloudRecording");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeCloudRecordingResponse rsp = DescribeCloudRecordingResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeCloudRecordingOutcome(rsp);
else
return DescribeCloudRecordingOutcome(o.GetError());
}
else
{
return DescribeCloudRecordingOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeCloudRecordingAsync(const DescribeCloudRecordingRequest& request, const DescribeCloudRecordingAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeCloudRecording(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeCloudRecordingOutcomeCallable TrtcClient::DescribeCloudRecordingCallable(const DescribeCloudRecordingRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeCloudRecordingOutcome()>>(
[this, request]()
{
return this->DescribeCloudRecording(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeMixTranscodingUsageOutcome TrtcClient::DescribeMixTranscodingUsage(const DescribeMixTranscodingUsageRequest &request)
{
auto outcome = MakeRequest(request, "DescribeMixTranscodingUsage");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeMixTranscodingUsageResponse rsp = DescribeMixTranscodingUsageResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeMixTranscodingUsageOutcome(rsp);
else
return DescribeMixTranscodingUsageOutcome(o.GetError());
}
else
{
return DescribeMixTranscodingUsageOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeMixTranscodingUsageAsync(const DescribeMixTranscodingUsageRequest& request, const DescribeMixTranscodingUsageAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeMixTranscodingUsage(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeMixTranscodingUsageOutcomeCallable TrtcClient::DescribeMixTranscodingUsageCallable(const DescribeMixTranscodingUsageRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeMixTranscodingUsageOutcome()>>(
[this, request]()
{
return this->DescribeMixTranscodingUsage(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribePictureOutcome TrtcClient::DescribePicture(const DescribePictureRequest &request)
{
auto outcome = MakeRequest(request, "DescribePicture");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribePictureResponse rsp = DescribePictureResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribePictureOutcome(rsp);
else
return DescribePictureOutcome(o.GetError());
}
else
{
return DescribePictureOutcome(outcome.GetError());
}
}
void TrtcClient::DescribePictureAsync(const DescribePictureRequest& request, const DescribePictureAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribePicture(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribePictureOutcomeCallable TrtcClient::DescribePictureCallable(const DescribePictureRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribePictureOutcome()>>(
[this, request]()
{
return this->DescribePicture(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeRecordStatisticOutcome TrtcClient::DescribeRecordStatistic(const DescribeRecordStatisticRequest &request)
{
auto outcome = MakeRequest(request, "DescribeRecordStatistic");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeRecordStatisticResponse rsp = DescribeRecordStatisticResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeRecordStatisticOutcome(rsp);
else
return DescribeRecordStatisticOutcome(o.GetError());
}
else
{
return DescribeRecordStatisticOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeRecordStatisticAsync(const DescribeRecordStatisticRequest& request, const DescribeRecordStatisticAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeRecordStatistic(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeRecordStatisticOutcomeCallable TrtcClient::DescribeRecordStatisticCallable(const DescribeRecordStatisticRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeRecordStatisticOutcome()>>(
[this, request]()
{
return this->DescribeRecordStatistic(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeRecordingUsageOutcome TrtcClient::DescribeRecordingUsage(const DescribeRecordingUsageRequest &request)
{
auto outcome = MakeRequest(request, "DescribeRecordingUsage");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeRecordingUsageResponse rsp = DescribeRecordingUsageResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeRecordingUsageOutcome(rsp);
else
return DescribeRecordingUsageOutcome(o.GetError());
}
else
{
return DescribeRecordingUsageOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeRecordingUsageAsync(const DescribeRecordingUsageRequest& request, const DescribeRecordingUsageAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeRecordingUsage(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeRecordingUsageOutcomeCallable TrtcClient::DescribeRecordingUsageCallable(const DescribeRecordingUsageRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeRecordingUsageOutcome()>>(
[this, request]()
{
return this->DescribeRecordingUsage(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeRelayUsageOutcome TrtcClient::DescribeRelayUsage(const DescribeRelayUsageRequest &request)
{
auto outcome = MakeRequest(request, "DescribeRelayUsage");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeRelayUsageResponse rsp = DescribeRelayUsageResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeRelayUsageOutcome(rsp);
else
return DescribeRelayUsageOutcome(o.GetError());
}
else
{
return DescribeRelayUsageOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeRelayUsageAsync(const DescribeRelayUsageRequest& request, const DescribeRelayUsageAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeRelayUsage(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeRelayUsageOutcomeCallable TrtcClient::DescribeRelayUsageCallable(const DescribeRelayUsageRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeRelayUsageOutcome()>>(
[this, request]()
{
return this->DescribeRelayUsage(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeRoomInfoOutcome TrtcClient::DescribeRoomInfo(const DescribeRoomInfoRequest &request)
{
auto outcome = MakeRequest(request, "DescribeRoomInfo");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeRoomInfoResponse rsp = DescribeRoomInfoResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeRoomInfoOutcome(rsp);
else
return DescribeRoomInfoOutcome(o.GetError());
}
else
{
return DescribeRoomInfoOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeRoomInfoAsync(const DescribeRoomInfoRequest& request, const DescribeRoomInfoAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeRoomInfo(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeRoomInfoOutcomeCallable TrtcClient::DescribeRoomInfoCallable(const DescribeRoomInfoRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeRoomInfoOutcome()>>(
[this, request]()
{
return this->DescribeRoomInfo(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeScaleInfoOutcome TrtcClient::DescribeScaleInfo(const DescribeScaleInfoRequest &request)
{
auto outcome = MakeRequest(request, "DescribeScaleInfo");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeScaleInfoResponse rsp = DescribeScaleInfoResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeScaleInfoOutcome(rsp);
else
return DescribeScaleInfoOutcome(o.GetError());
}
else
{
return DescribeScaleInfoOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeScaleInfoAsync(const DescribeScaleInfoRequest& request, const DescribeScaleInfoAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeScaleInfo(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeScaleInfoOutcomeCallable TrtcClient::DescribeScaleInfoCallable(const DescribeScaleInfoRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeScaleInfoOutcome()>>(
[this, request]()
{
return this->DescribeScaleInfo(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeStreamIngestOutcome TrtcClient::DescribeStreamIngest(const DescribeStreamIngestRequest &request)
{
auto outcome = MakeRequest(request, "DescribeStreamIngest");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeStreamIngestResponse rsp = DescribeStreamIngestResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeStreamIngestOutcome(rsp);
else
return DescribeStreamIngestOutcome(o.GetError());
}
else
{
return DescribeStreamIngestOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeStreamIngestAsync(const DescribeStreamIngestRequest& request, const DescribeStreamIngestAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeStreamIngest(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeStreamIngestOutcomeCallable TrtcClient::DescribeStreamIngestCallable(const DescribeStreamIngestRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeStreamIngestOutcome()>>(
[this, request]()
{
return this->DescribeStreamIngest(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeTRTCMarketQualityDataOutcome TrtcClient::DescribeTRTCMarketQualityData(const DescribeTRTCMarketQualityDataRequest &request)
{
auto outcome = MakeRequest(request, "DescribeTRTCMarketQualityData");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeTRTCMarketQualityDataResponse rsp = DescribeTRTCMarketQualityDataResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeTRTCMarketQualityDataOutcome(rsp);
else
return DescribeTRTCMarketQualityDataOutcome(o.GetError());
}
else
{
return DescribeTRTCMarketQualityDataOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeTRTCMarketQualityDataAsync(const DescribeTRTCMarketQualityDataRequest& request, const DescribeTRTCMarketQualityDataAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeTRTCMarketQualityData(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeTRTCMarketQualityDataOutcomeCallable TrtcClient::DescribeTRTCMarketQualityDataCallable(const DescribeTRTCMarketQualityDataRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeTRTCMarketQualityDataOutcome()>>(
[this, request]()
{
return this->DescribeTRTCMarketQualityData(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeTRTCMarketQualityMetricDataOutcome TrtcClient::DescribeTRTCMarketQualityMetricData(const DescribeTRTCMarketQualityMetricDataRequest &request)
{
auto outcome = MakeRequest(request, "DescribeTRTCMarketQualityMetricData");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeTRTCMarketQualityMetricDataResponse rsp = DescribeTRTCMarketQualityMetricDataResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeTRTCMarketQualityMetricDataOutcome(rsp);
else
return DescribeTRTCMarketQualityMetricDataOutcome(o.GetError());
}
else
{
return DescribeTRTCMarketQualityMetricDataOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeTRTCMarketQualityMetricDataAsync(const DescribeTRTCMarketQualityMetricDataRequest& request, const DescribeTRTCMarketQualityMetricDataAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeTRTCMarketQualityMetricData(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeTRTCMarketQualityMetricDataOutcomeCallable TrtcClient::DescribeTRTCMarketQualityMetricDataCallable(const DescribeTRTCMarketQualityMetricDataRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeTRTCMarketQualityMetricDataOutcome()>>(
[this, request]()
{
return this->DescribeTRTCMarketQualityMetricData(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeTRTCMarketScaleDataOutcome TrtcClient::DescribeTRTCMarketScaleData(const DescribeTRTCMarketScaleDataRequest &request)
{
auto outcome = MakeRequest(request, "DescribeTRTCMarketScaleData");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeTRTCMarketScaleDataResponse rsp = DescribeTRTCMarketScaleDataResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeTRTCMarketScaleDataOutcome(rsp);
else
return DescribeTRTCMarketScaleDataOutcome(o.GetError());
}
else
{
return DescribeTRTCMarketScaleDataOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeTRTCMarketScaleDataAsync(const DescribeTRTCMarketScaleDataRequest& request, const DescribeTRTCMarketScaleDataAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeTRTCMarketScaleData(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeTRTCMarketScaleDataOutcomeCallable TrtcClient::DescribeTRTCMarketScaleDataCallable(const DescribeTRTCMarketScaleDataRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeTRTCMarketScaleDataOutcome()>>(
[this, request]()
{
return this->DescribeTRTCMarketScaleData(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeTRTCMarketScaleMetricDataOutcome TrtcClient::DescribeTRTCMarketScaleMetricData(const DescribeTRTCMarketScaleMetricDataRequest &request)
{
auto outcome = MakeRequest(request, "DescribeTRTCMarketScaleMetricData");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeTRTCMarketScaleMetricDataResponse rsp = DescribeTRTCMarketScaleMetricDataResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeTRTCMarketScaleMetricDataOutcome(rsp);
else
return DescribeTRTCMarketScaleMetricDataOutcome(o.GetError());
}
else
{
return DescribeTRTCMarketScaleMetricDataOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeTRTCMarketScaleMetricDataAsync(const DescribeTRTCMarketScaleMetricDataRequest& request, const DescribeTRTCMarketScaleMetricDataAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeTRTCMarketScaleMetricData(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeTRTCMarketScaleMetricDataOutcomeCallable TrtcClient::DescribeTRTCMarketScaleMetricDataCallable(const DescribeTRTCMarketScaleMetricDataRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeTRTCMarketScaleMetricDataOutcome()>>(
[this, request]()
{
return this->DescribeTRTCMarketScaleMetricData(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeTRTCRealTimeQualityDataOutcome TrtcClient::DescribeTRTCRealTimeQualityData(const DescribeTRTCRealTimeQualityDataRequest &request)
{
auto outcome = MakeRequest(request, "DescribeTRTCRealTimeQualityData");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeTRTCRealTimeQualityDataResponse rsp = DescribeTRTCRealTimeQualityDataResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeTRTCRealTimeQualityDataOutcome(rsp);
else
return DescribeTRTCRealTimeQualityDataOutcome(o.GetError());
}
else
{
return DescribeTRTCRealTimeQualityDataOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeTRTCRealTimeQualityDataAsync(const DescribeTRTCRealTimeQualityDataRequest& request, const DescribeTRTCRealTimeQualityDataAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeTRTCRealTimeQualityData(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeTRTCRealTimeQualityDataOutcomeCallable TrtcClient::DescribeTRTCRealTimeQualityDataCallable(const DescribeTRTCRealTimeQualityDataRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeTRTCRealTimeQualityDataOutcome()>>(
[this, request]()
{
return this->DescribeTRTCRealTimeQualityData(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeTRTCRealTimeQualityMetricDataOutcome TrtcClient::DescribeTRTCRealTimeQualityMetricData(const DescribeTRTCRealTimeQualityMetricDataRequest &request)
{
auto outcome = MakeRequest(request, "DescribeTRTCRealTimeQualityMetricData");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeTRTCRealTimeQualityMetricDataResponse rsp = DescribeTRTCRealTimeQualityMetricDataResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeTRTCRealTimeQualityMetricDataOutcome(rsp);
else
return DescribeTRTCRealTimeQualityMetricDataOutcome(o.GetError());
}
else
{
return DescribeTRTCRealTimeQualityMetricDataOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeTRTCRealTimeQualityMetricDataAsync(const DescribeTRTCRealTimeQualityMetricDataRequest& request, const DescribeTRTCRealTimeQualityMetricDataAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeTRTCRealTimeQualityMetricData(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeTRTCRealTimeQualityMetricDataOutcomeCallable TrtcClient::DescribeTRTCRealTimeQualityMetricDataCallable(const DescribeTRTCRealTimeQualityMetricDataRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeTRTCRealTimeQualityMetricDataOutcome()>>(
[this, request]()
{
return this->DescribeTRTCRealTimeQualityMetricData(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeTRTCRealTimeScaleDataOutcome TrtcClient::DescribeTRTCRealTimeScaleData(const DescribeTRTCRealTimeScaleDataRequest &request)
{
auto outcome = MakeRequest(request, "DescribeTRTCRealTimeScaleData");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeTRTCRealTimeScaleDataResponse rsp = DescribeTRTCRealTimeScaleDataResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeTRTCRealTimeScaleDataOutcome(rsp);
else
return DescribeTRTCRealTimeScaleDataOutcome(o.GetError());
}
else
{
return DescribeTRTCRealTimeScaleDataOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeTRTCRealTimeScaleDataAsync(const DescribeTRTCRealTimeScaleDataRequest& request, const DescribeTRTCRealTimeScaleDataAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeTRTCRealTimeScaleData(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeTRTCRealTimeScaleDataOutcomeCallable TrtcClient::DescribeTRTCRealTimeScaleDataCallable(const DescribeTRTCRealTimeScaleDataRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeTRTCRealTimeScaleDataOutcome()>>(
[this, request]()
{
return this->DescribeTRTCRealTimeScaleData(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeTRTCRealTimeScaleMetricDataOutcome TrtcClient::DescribeTRTCRealTimeScaleMetricData(const DescribeTRTCRealTimeScaleMetricDataRequest &request)
{
auto outcome = MakeRequest(request, "DescribeTRTCRealTimeScaleMetricData");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeTRTCRealTimeScaleMetricDataResponse rsp = DescribeTRTCRealTimeScaleMetricDataResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeTRTCRealTimeScaleMetricDataOutcome(rsp);
else
return DescribeTRTCRealTimeScaleMetricDataOutcome(o.GetError());
}
else
{
return DescribeTRTCRealTimeScaleMetricDataOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeTRTCRealTimeScaleMetricDataAsync(const DescribeTRTCRealTimeScaleMetricDataRequest& request, const DescribeTRTCRealTimeScaleMetricDataAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeTRTCRealTimeScaleMetricData(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeTRTCRealTimeScaleMetricDataOutcomeCallable TrtcClient::DescribeTRTCRealTimeScaleMetricDataCallable(const DescribeTRTCRealTimeScaleMetricDataRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeTRTCRealTimeScaleMetricDataOutcome()>>(
[this, request]()
{
return this->DescribeTRTCRealTimeScaleMetricData(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeTrtcMcuTranscodeTimeOutcome TrtcClient::DescribeTrtcMcuTranscodeTime(const DescribeTrtcMcuTranscodeTimeRequest &request)
{
auto outcome = MakeRequest(request, "DescribeTrtcMcuTranscodeTime");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeTrtcMcuTranscodeTimeResponse rsp = DescribeTrtcMcuTranscodeTimeResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeTrtcMcuTranscodeTimeOutcome(rsp);
else
return DescribeTrtcMcuTranscodeTimeOutcome(o.GetError());
}
else
{
return DescribeTrtcMcuTranscodeTimeOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeTrtcMcuTranscodeTimeAsync(const DescribeTrtcMcuTranscodeTimeRequest& request, const DescribeTrtcMcuTranscodeTimeAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeTrtcMcuTranscodeTime(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeTrtcMcuTranscodeTimeOutcomeCallable TrtcClient::DescribeTrtcMcuTranscodeTimeCallable(const DescribeTrtcMcuTranscodeTimeRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeTrtcMcuTranscodeTimeOutcome()>>(
[this, request]()
{
return this->DescribeTrtcMcuTranscodeTime(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeTrtcRoomUsageOutcome TrtcClient::DescribeTrtcRoomUsage(const DescribeTrtcRoomUsageRequest &request)
{
auto outcome = MakeRequest(request, "DescribeTrtcRoomUsage");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeTrtcRoomUsageResponse rsp = DescribeTrtcRoomUsageResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeTrtcRoomUsageOutcome(rsp);
else
return DescribeTrtcRoomUsageOutcome(o.GetError());
}
else
{
return DescribeTrtcRoomUsageOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeTrtcRoomUsageAsync(const DescribeTrtcRoomUsageRequest& request, const DescribeTrtcRoomUsageAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeTrtcRoomUsage(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeTrtcRoomUsageOutcomeCallable TrtcClient::DescribeTrtcRoomUsageCallable(const DescribeTrtcRoomUsageRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeTrtcRoomUsageOutcome()>>(
[this, request]()
{
return this->DescribeTrtcRoomUsage(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeTrtcUsageOutcome TrtcClient::DescribeTrtcUsage(const DescribeTrtcUsageRequest &request)
{
auto outcome = MakeRequest(request, "DescribeTrtcUsage");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeTrtcUsageResponse rsp = DescribeTrtcUsageResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeTrtcUsageOutcome(rsp);
else
return DescribeTrtcUsageOutcome(o.GetError());
}
else
{
return DescribeTrtcUsageOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeTrtcUsageAsync(const DescribeTrtcUsageRequest& request, const DescribeTrtcUsageAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeTrtcUsage(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeTrtcUsageOutcomeCallable TrtcClient::DescribeTrtcUsageCallable(const DescribeTrtcUsageRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeTrtcUsageOutcome()>>(
[this, request]()
{
return this->DescribeTrtcUsage(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeUnusualEventOutcome TrtcClient::DescribeUnusualEvent(const DescribeUnusualEventRequest &request)
{
auto outcome = MakeRequest(request, "DescribeUnusualEvent");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeUnusualEventResponse rsp = DescribeUnusualEventResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeUnusualEventOutcome(rsp);
else
return DescribeUnusualEventOutcome(o.GetError());
}
else
{
return DescribeUnusualEventOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeUnusualEventAsync(const DescribeUnusualEventRequest& request, const DescribeUnusualEventAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeUnusualEvent(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeUnusualEventOutcomeCallable TrtcClient::DescribeUnusualEventCallable(const DescribeUnusualEventRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeUnusualEventOutcome()>>(
[this, request]()
{
return this->DescribeUnusualEvent(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeUserEventOutcome TrtcClient::DescribeUserEvent(const DescribeUserEventRequest &request)
{
auto outcome = MakeRequest(request, "DescribeUserEvent");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeUserEventResponse rsp = DescribeUserEventResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeUserEventOutcome(rsp);
else
return DescribeUserEventOutcome(o.GetError());
}
else
{
return DescribeUserEventOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeUserEventAsync(const DescribeUserEventRequest& request, const DescribeUserEventAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeUserEvent(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeUserEventOutcomeCallable TrtcClient::DescribeUserEventCallable(const DescribeUserEventRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeUserEventOutcome()>>(
[this, request]()
{
return this->DescribeUserEvent(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeUserInfoOutcome TrtcClient::DescribeUserInfo(const DescribeUserInfoRequest &request)
{
auto outcome = MakeRequest(request, "DescribeUserInfo");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeUserInfoResponse rsp = DescribeUserInfoResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeUserInfoOutcome(rsp);
else
return DescribeUserInfoOutcome(o.GetError());
}
else
{
return DescribeUserInfoOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeUserInfoAsync(const DescribeUserInfoRequest& request, const DescribeUserInfoAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeUserInfo(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeUserInfoOutcomeCallable TrtcClient::DescribeUserInfoCallable(const DescribeUserInfoRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeUserInfoOutcome()>>(
[this, request]()
{
return this->DescribeUserInfo(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeVoicePrintOutcome TrtcClient::DescribeVoicePrint(const DescribeVoicePrintRequest &request)
{
auto outcome = MakeRequest(request, "DescribeVoicePrint");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeVoicePrintResponse rsp = DescribeVoicePrintResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeVoicePrintOutcome(rsp);
else
return DescribeVoicePrintOutcome(o.GetError());
}
else
{
return DescribeVoicePrintOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeVoicePrintAsync(const DescribeVoicePrintRequest& request, const DescribeVoicePrintAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeVoicePrint(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeVoicePrintOutcomeCallable TrtcClient::DescribeVoicePrintCallable(const DescribeVoicePrintRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeVoicePrintOutcome()>>(
[this, request]()
{
return this->DescribeVoicePrint(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DescribeWebRecordOutcome TrtcClient::DescribeWebRecord(const DescribeWebRecordRequest &request)
{
auto outcome = MakeRequest(request, "DescribeWebRecord");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeWebRecordResponse rsp = DescribeWebRecordResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeWebRecordOutcome(rsp);
else
return DescribeWebRecordOutcome(o.GetError());
}
else
{
return DescribeWebRecordOutcome(outcome.GetError());
}
}
void TrtcClient::DescribeWebRecordAsync(const DescribeWebRecordRequest& request, const DescribeWebRecordAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeWebRecord(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DescribeWebRecordOutcomeCallable TrtcClient::DescribeWebRecordCallable(const DescribeWebRecordRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeWebRecordOutcome()>>(
[this, request]()
{
return this->DescribeWebRecord(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DismissRoomOutcome TrtcClient::DismissRoom(const DismissRoomRequest &request)
{
auto outcome = MakeRequest(request, "DismissRoom");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DismissRoomResponse rsp = DismissRoomResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DismissRoomOutcome(rsp);
else
return DismissRoomOutcome(o.GetError());
}
else
{
return DismissRoomOutcome(outcome.GetError());
}
}
void TrtcClient::DismissRoomAsync(const DismissRoomRequest& request, const DismissRoomAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DismissRoom(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DismissRoomOutcomeCallable TrtcClient::DismissRoomCallable(const DismissRoomRequest &request)
{
auto task = std::make_shared<std::packaged_task<DismissRoomOutcome()>>(
[this, request]()
{
return this->DismissRoom(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::DismissRoomByStrRoomIdOutcome TrtcClient::DismissRoomByStrRoomId(const DismissRoomByStrRoomIdRequest &request)
{
auto outcome = MakeRequest(request, "DismissRoomByStrRoomId");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DismissRoomByStrRoomIdResponse rsp = DismissRoomByStrRoomIdResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DismissRoomByStrRoomIdOutcome(rsp);
else
return DismissRoomByStrRoomIdOutcome(o.GetError());
}
else
{
return DismissRoomByStrRoomIdOutcome(outcome.GetError());
}
}
void TrtcClient::DismissRoomByStrRoomIdAsync(const DismissRoomByStrRoomIdRequest& request, const DismissRoomByStrRoomIdAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DismissRoomByStrRoomId(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::DismissRoomByStrRoomIdOutcomeCallable TrtcClient::DismissRoomByStrRoomIdCallable(const DismissRoomByStrRoomIdRequest &request)
{
auto task = std::make_shared<std::packaged_task<DismissRoomByStrRoomIdOutcome()>>(
[this, request]()
{
return this->DismissRoomByStrRoomId(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::ModifyCloudRecordingOutcome TrtcClient::ModifyCloudRecording(const ModifyCloudRecordingRequest &request)
{
auto outcome = MakeRequest(request, "ModifyCloudRecording");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
ModifyCloudRecordingResponse rsp = ModifyCloudRecordingResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return ModifyCloudRecordingOutcome(rsp);
else
return ModifyCloudRecordingOutcome(o.GetError());
}
else
{
return ModifyCloudRecordingOutcome(outcome.GetError());
}
}
void TrtcClient::ModifyCloudRecordingAsync(const ModifyCloudRecordingRequest& request, const ModifyCloudRecordingAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->ModifyCloudRecording(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::ModifyCloudRecordingOutcomeCallable TrtcClient::ModifyCloudRecordingCallable(const ModifyCloudRecordingRequest &request)
{
auto task = std::make_shared<std::packaged_task<ModifyCloudRecordingOutcome()>>(
[this, request]()
{
return this->ModifyCloudRecording(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::ModifyPictureOutcome TrtcClient::ModifyPicture(const ModifyPictureRequest &request)
{
auto outcome = MakeRequest(request, "ModifyPicture");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
ModifyPictureResponse rsp = ModifyPictureResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return ModifyPictureOutcome(rsp);
else
return ModifyPictureOutcome(o.GetError());
}
else
{
return ModifyPictureOutcome(outcome.GetError());
}
}
void TrtcClient::ModifyPictureAsync(const ModifyPictureRequest& request, const ModifyPictureAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->ModifyPicture(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::ModifyPictureOutcomeCallable TrtcClient::ModifyPictureCallable(const ModifyPictureRequest &request)
{
auto task = std::make_shared<std::packaged_task<ModifyPictureOutcome()>>(
[this, request]()
{
return this->ModifyPicture(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::RegisterVoicePrintOutcome TrtcClient::RegisterVoicePrint(const RegisterVoicePrintRequest &request)
{
auto outcome = MakeRequest(request, "RegisterVoicePrint");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
RegisterVoicePrintResponse rsp = RegisterVoicePrintResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return RegisterVoicePrintOutcome(rsp);
else
return RegisterVoicePrintOutcome(o.GetError());
}
else
{
return RegisterVoicePrintOutcome(outcome.GetError());
}
}
void TrtcClient::RegisterVoicePrintAsync(const RegisterVoicePrintRequest& request, const RegisterVoicePrintAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->RegisterVoicePrint(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::RegisterVoicePrintOutcomeCallable TrtcClient::RegisterVoicePrintCallable(const RegisterVoicePrintRequest &request)
{
auto task = std::make_shared<std::packaged_task<RegisterVoicePrintOutcome()>>(
[this, request]()
{
return this->RegisterVoicePrint(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::RemoveUserOutcome TrtcClient::RemoveUser(const RemoveUserRequest &request)
{
auto outcome = MakeRequest(request, "RemoveUser");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
RemoveUserResponse rsp = RemoveUserResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return RemoveUserOutcome(rsp);
else
return RemoveUserOutcome(o.GetError());
}
else
{
return RemoveUserOutcome(outcome.GetError());
}
}
void TrtcClient::RemoveUserAsync(const RemoveUserRequest& request, const RemoveUserAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->RemoveUser(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::RemoveUserOutcomeCallable TrtcClient::RemoveUserCallable(const RemoveUserRequest &request)
{
auto task = std::make_shared<std::packaged_task<RemoveUserOutcome()>>(
[this, request]()
{
return this->RemoveUser(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::RemoveUserByStrRoomIdOutcome TrtcClient::RemoveUserByStrRoomId(const RemoveUserByStrRoomIdRequest &request)
{
auto outcome = MakeRequest(request, "RemoveUserByStrRoomId");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
RemoveUserByStrRoomIdResponse rsp = RemoveUserByStrRoomIdResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return RemoveUserByStrRoomIdOutcome(rsp);
else
return RemoveUserByStrRoomIdOutcome(o.GetError());
}
else
{
return RemoveUserByStrRoomIdOutcome(outcome.GetError());
}
}
void TrtcClient::RemoveUserByStrRoomIdAsync(const RemoveUserByStrRoomIdRequest& request, const RemoveUserByStrRoomIdAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->RemoveUserByStrRoomId(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::RemoveUserByStrRoomIdOutcomeCallable TrtcClient::RemoveUserByStrRoomIdCallable(const RemoveUserByStrRoomIdRequest &request)
{
auto task = std::make_shared<std::packaged_task<RemoveUserByStrRoomIdOutcome()>>(
[this, request]()
{
return this->RemoveUserByStrRoomId(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::StartAIConversationOutcome TrtcClient::StartAIConversation(const StartAIConversationRequest &request)
{
auto outcome = MakeRequest(request, "StartAIConversation");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
StartAIConversationResponse rsp = StartAIConversationResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return StartAIConversationOutcome(rsp);
else
return StartAIConversationOutcome(o.GetError());
}
else
{
return StartAIConversationOutcome(outcome.GetError());
}
}
void TrtcClient::StartAIConversationAsync(const StartAIConversationRequest& request, const StartAIConversationAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->StartAIConversation(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::StartAIConversationOutcomeCallable TrtcClient::StartAIConversationCallable(const StartAIConversationRequest &request)
{
auto task = std::make_shared<std::packaged_task<StartAIConversationOutcome()>>(
[this, request]()
{
return this->StartAIConversation(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::StartAITranscriptionOutcome TrtcClient::StartAITranscription(const StartAITranscriptionRequest &request)
{
auto outcome = MakeRequest(request, "StartAITranscription");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
StartAITranscriptionResponse rsp = StartAITranscriptionResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return StartAITranscriptionOutcome(rsp);
else
return StartAITranscriptionOutcome(o.GetError());
}
else
{
return StartAITranscriptionOutcome(outcome.GetError());
}
}
void TrtcClient::StartAITranscriptionAsync(const StartAITranscriptionRequest& request, const StartAITranscriptionAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->StartAITranscription(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::StartAITranscriptionOutcomeCallable TrtcClient::StartAITranscriptionCallable(const StartAITranscriptionRequest &request)
{
auto task = std::make_shared<std::packaged_task<StartAITranscriptionOutcome()>>(
[this, request]()
{
return this->StartAITranscription(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::StartMCUMixTranscodeOutcome TrtcClient::StartMCUMixTranscode(const StartMCUMixTranscodeRequest &request)
{
auto outcome = MakeRequest(request, "StartMCUMixTranscode");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
StartMCUMixTranscodeResponse rsp = StartMCUMixTranscodeResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return StartMCUMixTranscodeOutcome(rsp);
else
return StartMCUMixTranscodeOutcome(o.GetError());
}
else
{
return StartMCUMixTranscodeOutcome(outcome.GetError());
}
}
void TrtcClient::StartMCUMixTranscodeAsync(const StartMCUMixTranscodeRequest& request, const StartMCUMixTranscodeAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->StartMCUMixTranscode(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::StartMCUMixTranscodeOutcomeCallable TrtcClient::StartMCUMixTranscodeCallable(const StartMCUMixTranscodeRequest &request)
{
auto task = std::make_shared<std::packaged_task<StartMCUMixTranscodeOutcome()>>(
[this, request]()
{
return this->StartMCUMixTranscode(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::StartMCUMixTranscodeByStrRoomIdOutcome TrtcClient::StartMCUMixTranscodeByStrRoomId(const StartMCUMixTranscodeByStrRoomIdRequest &request)
{
auto outcome = MakeRequest(request, "StartMCUMixTranscodeByStrRoomId");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
StartMCUMixTranscodeByStrRoomIdResponse rsp = StartMCUMixTranscodeByStrRoomIdResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return StartMCUMixTranscodeByStrRoomIdOutcome(rsp);
else
return StartMCUMixTranscodeByStrRoomIdOutcome(o.GetError());
}
else
{
return StartMCUMixTranscodeByStrRoomIdOutcome(outcome.GetError());
}
}
void TrtcClient::StartMCUMixTranscodeByStrRoomIdAsync(const StartMCUMixTranscodeByStrRoomIdRequest& request, const StartMCUMixTranscodeByStrRoomIdAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->StartMCUMixTranscodeByStrRoomId(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::StartMCUMixTranscodeByStrRoomIdOutcomeCallable TrtcClient::StartMCUMixTranscodeByStrRoomIdCallable(const StartMCUMixTranscodeByStrRoomIdRequest &request)
{
auto task = std::make_shared<std::packaged_task<StartMCUMixTranscodeByStrRoomIdOutcome()>>(
[this, request]()
{
return this->StartMCUMixTranscodeByStrRoomId(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::StartPublishCdnStreamOutcome TrtcClient::StartPublishCdnStream(const StartPublishCdnStreamRequest &request)
{
auto outcome = MakeRequest(request, "StartPublishCdnStream");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
StartPublishCdnStreamResponse rsp = StartPublishCdnStreamResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return StartPublishCdnStreamOutcome(rsp);
else
return StartPublishCdnStreamOutcome(o.GetError());
}
else
{
return StartPublishCdnStreamOutcome(outcome.GetError());
}
}
void TrtcClient::StartPublishCdnStreamAsync(const StartPublishCdnStreamRequest& request, const StartPublishCdnStreamAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->StartPublishCdnStream(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::StartPublishCdnStreamOutcomeCallable TrtcClient::StartPublishCdnStreamCallable(const StartPublishCdnStreamRequest &request)
{
auto task = std::make_shared<std::packaged_task<StartPublishCdnStreamOutcome()>>(
[this, request]()
{
return this->StartPublishCdnStream(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::StartStreamIngestOutcome TrtcClient::StartStreamIngest(const StartStreamIngestRequest &request)
{
auto outcome = MakeRequest(request, "StartStreamIngest");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
StartStreamIngestResponse rsp = StartStreamIngestResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return StartStreamIngestOutcome(rsp);
else
return StartStreamIngestOutcome(o.GetError());
}
else
{
return StartStreamIngestOutcome(outcome.GetError());
}
}
void TrtcClient::StartStreamIngestAsync(const StartStreamIngestRequest& request, const StartStreamIngestAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->StartStreamIngest(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::StartStreamIngestOutcomeCallable TrtcClient::StartStreamIngestCallable(const StartStreamIngestRequest &request)
{
auto task = std::make_shared<std::packaged_task<StartStreamIngestOutcome()>>(
[this, request]()
{
return this->StartStreamIngest(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::StartWebRecordOutcome TrtcClient::StartWebRecord(const StartWebRecordRequest &request)
{
auto outcome = MakeRequest(request, "StartWebRecord");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
StartWebRecordResponse rsp = StartWebRecordResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return StartWebRecordOutcome(rsp);
else
return StartWebRecordOutcome(o.GetError());
}
else
{
return StartWebRecordOutcome(outcome.GetError());
}
}
void TrtcClient::StartWebRecordAsync(const StartWebRecordRequest& request, const StartWebRecordAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->StartWebRecord(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::StartWebRecordOutcomeCallable TrtcClient::StartWebRecordCallable(const StartWebRecordRequest &request)
{
auto task = std::make_shared<std::packaged_task<StartWebRecordOutcome()>>(
[this, request]()
{
return this->StartWebRecord(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::StopAIConversationOutcome TrtcClient::StopAIConversation(const StopAIConversationRequest &request)
{
auto outcome = MakeRequest(request, "StopAIConversation");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
StopAIConversationResponse rsp = StopAIConversationResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return StopAIConversationOutcome(rsp);
else
return StopAIConversationOutcome(o.GetError());
}
else
{
return StopAIConversationOutcome(outcome.GetError());
}
}
void TrtcClient::StopAIConversationAsync(const StopAIConversationRequest& request, const StopAIConversationAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->StopAIConversation(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::StopAIConversationOutcomeCallable TrtcClient::StopAIConversationCallable(const StopAIConversationRequest &request)
{
auto task = std::make_shared<std::packaged_task<StopAIConversationOutcome()>>(
[this, request]()
{
return this->StopAIConversation(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::StopAITranscriptionOutcome TrtcClient::StopAITranscription(const StopAITranscriptionRequest &request)
{
auto outcome = MakeRequest(request, "StopAITranscription");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
StopAITranscriptionResponse rsp = StopAITranscriptionResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return StopAITranscriptionOutcome(rsp);
else
return StopAITranscriptionOutcome(o.GetError());
}
else
{
return StopAITranscriptionOutcome(outcome.GetError());
}
}
void TrtcClient::StopAITranscriptionAsync(const StopAITranscriptionRequest& request, const StopAITranscriptionAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->StopAITranscription(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::StopAITranscriptionOutcomeCallable TrtcClient::StopAITranscriptionCallable(const StopAITranscriptionRequest &request)
{
auto task = std::make_shared<std::packaged_task<StopAITranscriptionOutcome()>>(
[this, request]()
{
return this->StopAITranscription(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::StopMCUMixTranscodeOutcome TrtcClient::StopMCUMixTranscode(const StopMCUMixTranscodeRequest &request)
{
auto outcome = MakeRequest(request, "StopMCUMixTranscode");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
StopMCUMixTranscodeResponse rsp = StopMCUMixTranscodeResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return StopMCUMixTranscodeOutcome(rsp);
else
return StopMCUMixTranscodeOutcome(o.GetError());
}
else
{
return StopMCUMixTranscodeOutcome(outcome.GetError());
}
}
void TrtcClient::StopMCUMixTranscodeAsync(const StopMCUMixTranscodeRequest& request, const StopMCUMixTranscodeAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->StopMCUMixTranscode(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::StopMCUMixTranscodeOutcomeCallable TrtcClient::StopMCUMixTranscodeCallable(const StopMCUMixTranscodeRequest &request)
{
auto task = std::make_shared<std::packaged_task<StopMCUMixTranscodeOutcome()>>(
[this, request]()
{
return this->StopMCUMixTranscode(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::StopMCUMixTranscodeByStrRoomIdOutcome TrtcClient::StopMCUMixTranscodeByStrRoomId(const StopMCUMixTranscodeByStrRoomIdRequest &request)
{
auto outcome = MakeRequest(request, "StopMCUMixTranscodeByStrRoomId");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
StopMCUMixTranscodeByStrRoomIdResponse rsp = StopMCUMixTranscodeByStrRoomIdResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return StopMCUMixTranscodeByStrRoomIdOutcome(rsp);
else
return StopMCUMixTranscodeByStrRoomIdOutcome(o.GetError());
}
else
{
return StopMCUMixTranscodeByStrRoomIdOutcome(outcome.GetError());
}
}
void TrtcClient::StopMCUMixTranscodeByStrRoomIdAsync(const StopMCUMixTranscodeByStrRoomIdRequest& request, const StopMCUMixTranscodeByStrRoomIdAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->StopMCUMixTranscodeByStrRoomId(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::StopMCUMixTranscodeByStrRoomIdOutcomeCallable TrtcClient::StopMCUMixTranscodeByStrRoomIdCallable(const StopMCUMixTranscodeByStrRoomIdRequest &request)
{
auto task = std::make_shared<std::packaged_task<StopMCUMixTranscodeByStrRoomIdOutcome()>>(
[this, request]()
{
return this->StopMCUMixTranscodeByStrRoomId(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::StopPublishCdnStreamOutcome TrtcClient::StopPublishCdnStream(const StopPublishCdnStreamRequest &request)
{
auto outcome = MakeRequest(request, "StopPublishCdnStream");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
StopPublishCdnStreamResponse rsp = StopPublishCdnStreamResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return StopPublishCdnStreamOutcome(rsp);
else
return StopPublishCdnStreamOutcome(o.GetError());
}
else
{
return StopPublishCdnStreamOutcome(outcome.GetError());
}
}
void TrtcClient::StopPublishCdnStreamAsync(const StopPublishCdnStreamRequest& request, const StopPublishCdnStreamAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->StopPublishCdnStream(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::StopPublishCdnStreamOutcomeCallable TrtcClient::StopPublishCdnStreamCallable(const StopPublishCdnStreamRequest &request)
{
auto task = std::make_shared<std::packaged_task<StopPublishCdnStreamOutcome()>>(
[this, request]()
{
return this->StopPublishCdnStream(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::StopStreamIngestOutcome TrtcClient::StopStreamIngest(const StopStreamIngestRequest &request)
{
auto outcome = MakeRequest(request, "StopStreamIngest");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
StopStreamIngestResponse rsp = StopStreamIngestResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return StopStreamIngestOutcome(rsp);
else
return StopStreamIngestOutcome(o.GetError());
}
else
{
return StopStreamIngestOutcome(outcome.GetError());
}
}
void TrtcClient::StopStreamIngestAsync(const StopStreamIngestRequest& request, const StopStreamIngestAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->StopStreamIngest(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::StopStreamIngestOutcomeCallable TrtcClient::StopStreamIngestCallable(const StopStreamIngestRequest &request)
{
auto task = std::make_shared<std::packaged_task<StopStreamIngestOutcome()>>(
[this, request]()
{
return this->StopStreamIngest(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::StopWebRecordOutcome TrtcClient::StopWebRecord(const StopWebRecordRequest &request)
{
auto outcome = MakeRequest(request, "StopWebRecord");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
StopWebRecordResponse rsp = StopWebRecordResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return StopWebRecordOutcome(rsp);
else
return StopWebRecordOutcome(o.GetError());
}
else
{
return StopWebRecordOutcome(outcome.GetError());
}
}
void TrtcClient::StopWebRecordAsync(const StopWebRecordRequest& request, const StopWebRecordAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->StopWebRecord(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::StopWebRecordOutcomeCallable TrtcClient::StopWebRecordCallable(const StopWebRecordRequest &request)
{
auto task = std::make_shared<std::packaged_task<StopWebRecordOutcome()>>(
[this, request]()
{
return this->StopWebRecord(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::UpdateAIConversationOutcome TrtcClient::UpdateAIConversation(const UpdateAIConversationRequest &request)
{
auto outcome = MakeRequest(request, "UpdateAIConversation");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
UpdateAIConversationResponse rsp = UpdateAIConversationResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return UpdateAIConversationOutcome(rsp);
else
return UpdateAIConversationOutcome(o.GetError());
}
else
{
return UpdateAIConversationOutcome(outcome.GetError());
}
}
void TrtcClient::UpdateAIConversationAsync(const UpdateAIConversationRequest& request, const UpdateAIConversationAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->UpdateAIConversation(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::UpdateAIConversationOutcomeCallable TrtcClient::UpdateAIConversationCallable(const UpdateAIConversationRequest &request)
{
auto task = std::make_shared<std::packaged_task<UpdateAIConversationOutcome()>>(
[this, request]()
{
return this->UpdateAIConversation(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::UpdatePublishCdnStreamOutcome TrtcClient::UpdatePublishCdnStream(const UpdatePublishCdnStreamRequest &request)
{
auto outcome = MakeRequest(request, "UpdatePublishCdnStream");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
UpdatePublishCdnStreamResponse rsp = UpdatePublishCdnStreamResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return UpdatePublishCdnStreamOutcome(rsp);
else
return UpdatePublishCdnStreamOutcome(o.GetError());
}
else
{
return UpdatePublishCdnStreamOutcome(outcome.GetError());
}
}
void TrtcClient::UpdatePublishCdnStreamAsync(const UpdatePublishCdnStreamRequest& request, const UpdatePublishCdnStreamAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->UpdatePublishCdnStream(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::UpdatePublishCdnStreamOutcomeCallable TrtcClient::UpdatePublishCdnStreamCallable(const UpdatePublishCdnStreamRequest &request)
{
auto task = std::make_shared<std::packaged_task<UpdatePublishCdnStreamOutcome()>>(
[this, request]()
{
return this->UpdatePublishCdnStream(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::UpdateStreamIngestOutcome TrtcClient::UpdateStreamIngest(const UpdateStreamIngestRequest &request)
{
auto outcome = MakeRequest(request, "UpdateStreamIngest");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
UpdateStreamIngestResponse rsp = UpdateStreamIngestResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return UpdateStreamIngestOutcome(rsp);
else
return UpdateStreamIngestOutcome(o.GetError());
}
else
{
return UpdateStreamIngestOutcome(outcome.GetError());
}
}
void TrtcClient::UpdateStreamIngestAsync(const UpdateStreamIngestRequest& request, const UpdateStreamIngestAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->UpdateStreamIngest(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::UpdateStreamIngestOutcomeCallable TrtcClient::UpdateStreamIngestCallable(const UpdateStreamIngestRequest &request)
{
auto task = std::make_shared<std::packaged_task<UpdateStreamIngestOutcome()>>(
[this, request]()
{
return this->UpdateStreamIngest(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TrtcClient::UpdateVoicePrintOutcome TrtcClient::UpdateVoicePrint(const UpdateVoicePrintRequest &request)
{
auto outcome = MakeRequest(request, "UpdateVoicePrint");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
UpdateVoicePrintResponse rsp = UpdateVoicePrintResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return UpdateVoicePrintOutcome(rsp);
else
return UpdateVoicePrintOutcome(o.GetError());
}
else
{
return UpdateVoicePrintOutcome(outcome.GetError());
}
}
void TrtcClient::UpdateVoicePrintAsync(const UpdateVoicePrintRequest& request, const UpdateVoicePrintAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->UpdateVoicePrint(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TrtcClient::UpdateVoicePrintOutcomeCallable TrtcClient::UpdateVoicePrintCallable(const UpdateVoicePrintRequest &request)
{
auto task = std::make_shared<std::packaged_task<UpdateVoicePrintOutcome()>>(
[this, request]()
{
return this->UpdateVoicePrint(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/tencentcloud/tencentcloud-sdk-cpp.git
git@gitee.com:tencentcloud/tencentcloud-sdk-cpp.git
tencentcloud
tencentcloud-sdk-cpp
tencentcloud-sdk-cpp
master

搜索帮助