summaryrefslogtreecommitdiff
path: root/cpp/include/Ice/OutgoingAsync.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/include/Ice/OutgoingAsync.h')
-rw-r--r--cpp/include/Ice/OutgoingAsync.h23
1 files changed, 11 insertions, 12 deletions
diff --git a/cpp/include/Ice/OutgoingAsync.h b/cpp/include/Ice/OutgoingAsync.h
index fafceba4f52..b5bd6830117 100644
--- a/cpp/include/Ice/OutgoingAsync.h
+++ b/cpp/include/Ice/OutgoingAsync.h
@@ -248,7 +248,7 @@ class ICE_API OutgoingAsync : public ProxyOutgoingAsyncBase
{
public:
- OutgoingAsync(const Ice::ObjectPrxPtr&);
+ OutgoingAsync(const Ice::ObjectPrxPtr&, bool);
void prepare(const std::string&, Ice::OperationMode, const Ice::Context&);
@@ -548,7 +548,7 @@ public:
std::function<void(R)> response,
std::function<void(::std::exception_ptr)> ex,
std::function<void(bool)> sent) :
- OutgoingAsyncT<R>(proxy), LambdaInvoke(std::move(ex), std::move(sent))
+ OutgoingAsyncT<R>(proxy, false), LambdaInvoke(std::move(ex), std::move(sent))
{
_response = [this, response](bool ok)
{
@@ -584,7 +584,7 @@ public:
std::function<void()> response,
std::function<void(::std::exception_ptr)> ex,
std::function<void(bool)> sent) :
- OutgoingAsyncT<void>(proxy), LambdaInvoke(std::move(ex), std::move(sent))
+ OutgoingAsyncT<void>(proxy, false), LambdaInvoke(std::move(ex), std::move(sent))
{
_response = [this, response](bool ok)
{
@@ -620,7 +620,7 @@ public:
std::function<void(Ice::InputStream*)> read,
std::function<void(::std::exception_ptr)> ex,
std::function<void(bool)> sent) :
- OutgoingAsync(proxy), LambdaInvoke(std::move(ex), std::move(sent))
+ OutgoingAsync(proxy, false), LambdaInvoke(std::move(ex), std::move(sent))
{
_response = [this, read](bool ok)
{
@@ -656,10 +656,9 @@ class PromiseOutgoing : public OutgoingAsyncT<R>, public PromiseInvoke<P>
{
public:
- PromiseOutgoing(const std::shared_ptr<Ice::ObjectPrx>& proxy, bool synchronous) :
- OutgoingAsyncT<R>(proxy)
+ PromiseOutgoing(const std::shared_ptr<Ice::ObjectPrx>& proxy, bool sync) :
+ OutgoingAsyncT<R>(proxy, sync)
{
- this->_synchronous = synchronous;
this->_response = [this](bool ok)
{
if(ok)
@@ -683,10 +682,9 @@ class PromiseOutgoing<P, void> : public OutgoingAsyncT<void>, public PromiseInvo
{
public:
- PromiseOutgoing(const std::shared_ptr<Ice::ObjectPrx>& proxy, bool synchronous) :
- OutgoingAsyncT<void>(proxy)
+ PromiseOutgoing(const std::shared_ptr<Ice::ObjectPrx>& proxy, bool sync) :
+ OutgoingAsyncT<void>(proxy, sync)
{
- this->_synchronous = synchronous;
this->_response = [&](bool ok)
{
if(this->_is.b.empty())
@@ -860,8 +858,9 @@ public:
CallbackOutgoing(const Ice::ObjectPrx& proxy,
const std::string& operation,
const CallbackBasePtr& cb,
- const Ice::LocalObjectPtr& cookie) :
- OutgoingAsync(proxy), CallbackCompletion(cb, cookie), _operation(operation)
+ const Ice::LocalObjectPtr& cookie,
+ bool sync) :
+ OutgoingAsync(proxy, sync), CallbackCompletion(cb, cookie), _operation(operation)
{
_cookie = cookie;
}