summaryrefslogtreecommitdiffstats
path: root/async/src/async.cpp
diff options
context:
space:
mode:
authorDan Vrátil <dvratil@redhat.com>2015-05-15 16:00:32 +0200
committerDan Vrátil <dvratil@redhat.com>2015-05-15 16:22:28 +0200
commit5b78e0da1d64b6096829f54b29f14ec5643b5ece (patch)
tree2091795596f9721bc1d9d8cb9965103d5a32df7a /async/src/async.cpp
parent3bbee6c42683db5f85b01e4eb6dab8135e199f6c (diff)
downloadsink-5b78e0da1d64b6096829f54b29f14ec5643b5ece.tar.gz
sink-5b78e0da1d64b6096829f54b29f14ec5643b5ece.zip
Async: rename Async namespace to KAsync
Diffstat (limited to 'async/src/async.cpp')
-rw-r--r--async/src/async.cpp18
1 files changed, 9 insertions, 9 deletions
diff --git a/async/src/async.cpp b/async/src/async.cpp
index 0e86a84..c57c9ad 100644
--- a/async/src/async.cpp
+++ b/async/src/async.cpp
@@ -22,7 +22,7 @@
22#include <QEventLoop> 22#include <QEventLoop>
23#include <QTimer> 23#include <QTimer>
24 24
25using namespace Async; 25using namespace KAsync;
26 26
27Private::Execution::Execution(const Private::ExecutorBasePtr &executor) 27Private::Execution::Execution(const Private::ExecutorBasePtr &executor)
28 : executor(executor) 28 : executor(executor)
@@ -104,11 +104,11 @@ static void asyncWhile(const std::function<void(std::function<void(bool)>)> &bod
104 }); 104 });
105} 105}
106 106
107Job<void> Async::dowhile(Condition condition, ThenTask<void> body) 107Job<void> KAsync::dowhile(Condition condition, ThenTask<void> body)
108{ 108{
109 return Async::start<void>([body, condition](Async::Future<void> &future) { 109 return KAsync::start<void>([body, condition](KAsync::Future<void> &future) {
110 asyncWhile([condition, body](std::function<void(bool)> whileCallback) { 110 asyncWhile([condition, body](std::function<void(bool)> whileCallback) {
111 Async::start<void>(body).then<void>([whileCallback, condition]() { 111 KAsync::start<void>(body).then<void>([whileCallback, condition]() {
112 whileCallback(!condition()); 112 whileCallback(!condition());
113 }).exec(); 113 }).exec();
114 }, 114 },
@@ -118,11 +118,11 @@ Job<void> Async::dowhile(Condition condition, ThenTask<void> body)
118 }); 118 });
119} 119}
120 120
121Job<void> Async::dowhile(ThenTask<bool> body) 121Job<void> KAsync::dowhile(ThenTask<bool> body)
122{ 122{
123 return Async::start<void>([body](Async::Future<void> &future) { 123 return KAsync::start<void>([body](KAsync::Future<void> &future) {
124 asyncWhile([body](std::function<void(bool)> whileCallback) { 124 asyncWhile([body](std::function<void(bool)> whileCallback) {
125 Async::start<bool>(body).then<bool, bool>([whileCallback](bool result) { 125 KAsync::start<bool>(body).then<bool, bool>([whileCallback](bool result) {
126 whileCallback(!result); 126 whileCallback(!result);
127 //FIXME this return value is only required because .then<bool, void> doesn't work 127 //FIXME this return value is only required because .then<bool, void> doesn't work
128 return true; 128 return true;
@@ -134,10 +134,10 @@ Job<void> Async::dowhile(ThenTask<bool> body)
134 }); 134 });
135} 135}
136 136
137Job<void> Async::wait(int delay) 137Job<void> KAsync::wait(int delay)
138{ 138{
139 auto timer = QSharedPointer<QTimer>::create(); 139 auto timer = QSharedPointer<QTimer>::create();
140 return Async::start<void>([timer, delay](Async::Future<void> &future) { 140 return KAsync::start<void>([timer, delay](KAsync::Future<void> &future) {
141 timer->setSingleShot(true); 141 timer->setSingleShot(true);
142 QObject::connect(timer.data(), &QTimer::timeout, [&future]() { 142 QObject::connect(timer.data(), &QTimer::timeout, [&future]() {
143 future.setFinished(); 143 future.setFinished();