4 files changed, 23 insertions, 9 deletions

diff --git a/async/src/async.cpp b/async/src/async.cpp
index e1d4806..e24b769 100644
--- a/async/src/async.cpp
+++ b/async/src/async.cpp
@@ -48,3 +48,4 @@ JobBase::JobBase(Private::ExecutorBase *executor)
 JobBase::~JobBase()
 {
 }
+
diff --git a/async/src/async.h b/async/src/async.h
index 233ad56..5866b34 100644
--- a/async/src/async.h
+++ b/async/src/async.h
@@ -251,8 +251,7 @@ public:
 private:
     Job(Private::ExecutorBase *executor)
         : JobBase(executor)
-    {
-    }
+    {}
 };
 
 } // namespace Async
diff --git a/async/src/future.cpp b/async/src/future.cpp
index 48c7417..dcbec32 100644
--- a/async/src/future.cpp
+++ b/async/src/future.cpp
@@ -25,13 +25,11 @@ using namespace Async;
 
 FutureBase::FutureBase()
     : mFinished(false)
-    , mWaitLoop(nullptr)
 {
 }
 
 FutureBase::FutureBase(const Async::FutureBase &other)
     : mFinished(other.mFinished)
-    , mWaitLoop(other.mWaitLoop)
 {
 }
 
diff --git a/async/src/future.h b/async/src/future.h
index 39e3936..ecd6931 100644
--- a/async/src/future.h
+++ b/async/src/future.h
@@ -29,6 +29,7 @@ class QEventLoop;
 #include <QSharedDataPointer>
 #include <QPointer>
 #include <QVector>
+#include <QEventLoop>
 
 namespace Async {
 
@@ -45,13 +46,15 @@ protected:
     FutureBase(const FutureBase &other);
 
     bool mFinished;
-    QEventLoop *mWaitLoop;
 };
 
 template<typename T>
 class FutureWatcher;
 
 template<typename T>
+class Future;
+
+template<typename T>
 class FutureGeneric : public FutureBase
 {
     friend class FutureWatcher<T>;
@@ -67,15 +70,28 @@ public:
         }
     }
 
+    void waitForFinished()
+    {
+        if (isFinished()) {
+            return;
+        }
+        FutureWatcher<T> watcher;
+        QEventLoop eventLoop;
+        QObject::connect(&watcher, &Async::FutureWatcher<T>::futureReady,
+                         &eventLoop, &QEventLoop::quit);
+        watcher.setFuture(*static_cast<Async::Future<T>*>(this));
+        eventLoop.exec();
+    }
+
 protected:
     FutureGeneric()
-    : FutureBase()
-    , d(new Private)
+        : FutureBase()
+        , d(new Private)
     {}
 
     FutureGeneric(const FutureGeneric<T> &other)
-    : FutureBase(other)
-    , d(other.d)
+        : FutureBase(other)
+        , d(other.d)
     {}
 
     class Private : public QSharedData