1585346868/aliyun-openapi-cpp-sdk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Support continuous pushing.

Browse Source
This commit is contained in:
sdk-team
2019-10-14 14:05:26 +08:00
parent 0dc8a66e75
commit 8fe6dfd981
13 changed files with 560 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

72
push/src/PushClient.cc
View File

@@ -267,6 +267,78 @@ PushClient::CheckDevicesOutcomeCallable PushClient::checkDevicesCallable(const C
return task->get_future();
}
PushClient::CompleteContinuouslyPushOutcome PushClient::completeContinuouslyPush(const CompleteContinuouslyPushRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return CompleteContinuouslyPushOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return CompleteContinuouslyPushOutcome(CompleteContinuouslyPushResult(outcome.result()));
else
return CompleteContinuouslyPushOutcome(outcome.error());
}
void PushClient::completeContinuouslyPushAsync(const CompleteContinuouslyPushRequest& request, const CompleteContinuouslyPushAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, completeContinuouslyPush(request), context);
};
asyncExecute(new Runnable(fn));
}
PushClient::CompleteContinuouslyPushOutcomeCallable PushClient::completeContinuouslyPushCallable(const CompleteContinuouslyPushRequest &request) const
{
auto task = std::make_shared<std::packaged_task<CompleteContinuouslyPushOutcome()>>(
[this, request]()
{
return this->completeContinuouslyPush(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PushClient::ContinuouslyPushOutcome PushClient::continuouslyPush(const ContinuouslyPushRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return ContinuouslyPushOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return ContinuouslyPushOutcome(ContinuouslyPushResult(outcome.result()));
else
return ContinuouslyPushOutcome(outcome.error());
}
void PushClient::continuouslyPushAsync(const ContinuouslyPushRequest& request, const ContinuouslyPushAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, continuouslyPush(request), context);
};
asyncExecute(new Runnable(fn));
}
PushClient::ContinuouslyPushOutcomeCallable PushClient::continuouslyPushCallable(const ContinuouslyPushRequest &request) const
{
auto task = std::make_shared<std::packaged_task<ContinuouslyPushOutcome()>>(
[this, request]()
{
return this->continuouslyPush(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PushClient::ListPushRecordsOutcome PushClient::listPushRecords(const ListPushRecordsRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();