From 65131b9470455ae52a86d811882ca1d97c4a899c Mon Sep 17 00:00:00 2001
From: Christian Mollekopf <chrigi_1@fastmail.fm>
Date: Wed, 1 Apr 2015 01:40:23 +0200
Subject: Use Async::while

---
 dummyresource/resourcefactory.cpp | 31 +++++++++++--------------------
 1 file changed, 11 insertions(+), 20 deletions(-)

diff --git a/dummyresource/resourcefactory.cpp b/dummyresource/resourcefactory.cpp
index d2b0c14..c0395b7 100644
--- a/dummyresource/resourcefactory.cpp
+++ b/dummyresource/resourcefactory.cpp
@@ -210,26 +210,17 @@ private slots:
 
     Async::Job<void> processPipeline()
     {
-        auto job = Async::start<void>([this](Async::Future<void> &future) {
-            //An async for loop. Go through all message queues
-            //TODO: replace by Async::foreach
-            auto it = QSharedPointer<QListIterator<MessageQueue*> >::create(mCommandQueues);
-            asyncWhile([&, it](std::function<void(bool)> forCallback) {
-                if (it->hasNext()) {
-                    auto queue = it->next();
-                    processQueue(queue).then<void>([forCallback]() {
-                      forCallback(false);
-                    }).exec();
-                } else {
-                    forCallback(true);
-                }
-            },
-            [&future]() { //while complete
-                future.setFinished();
-            });
-
-        });
-        return job;
+        //Go through all message queues
+        auto it = QSharedPointer<QListIterator<MessageQueue*> >::create(mCommandQueues);
+        return Async::dowhile<void>(
+            [it]() { return it->hasNext(); },
+            [it, this](Async::Future<void> &future) {
+                auto queue = it->next();
+                processQueue(queue).then<void>([&future]() {
+                    future.setFinished();
+                }).exec();
+            }
+        );
     }
 
 private:
-- 
cgit v1.2.3