3 files changed, 11 insertions, 14 deletions

diff --git a/async/src/async.h b/async/src/async.h
index 171a245..8fee0bc 100644
--- a/async/src/async.h
+++ b/async/src/async.h
@@ -300,8 +300,7 @@ void Executor<PrevOut, Out, In ...>::exec()
         auto futureWatcher = new Async::FutureWatcher<PrevOut>();
         QObject::connect(futureWatcher, &Async::FutureWatcher<PrevOut>::futureReady,
                          [futureWatcher, this]() {
-                            //FIXME mFinished is not part of the d-pointer but we copy the future below
-                             // assert(futureWatcher->future().isFinished());
+                             assert(futureWatcher->future().isFinished());
                              futureWatcher->deleteLater();
                              previousFutureReady();
                          });
@@ -320,7 +319,7 @@ template<typename Out, typename ... In>
 void ThenExecutor<Out, In ...>::previousFutureReady()
 {
     if (this->mPrevFuture) {
-            assert(this->mPrevFuture->isFinished());
+        assert(this->mPrevFuture->isFinished());
     }
     this->mFunc(this->mPrevFuture ? this->mPrevFuture->value() : In() ...,
                 *static_cast<Async::Future<Out>*>(this->mResult));
diff --git a/async/src/future.cpp b/async/src/future.cpp
index 4b34514..ab02baf 100644
--- a/async/src/future.cpp
+++ b/async/src/future.cpp
@@ -20,12 +20,10 @@
 using namespace Async;
 
 FutureBase::FutureBase()
-    : mFinished(false)
 {
 }
 
 FutureBase::FutureBase(const Async::FutureBase &other)
-    : mFinished(other.mFinished)
 {
 }
 
@@ -33,11 +31,6 @@ FutureBase::~FutureBase()
 {
 }
 
-bool FutureBase::isFinished() const
-{
-    return mFinished;
-}
-
 FutureWatcherBase::FutureWatcherBase(QObject *parent)
     : QObject(parent)
 {
diff --git a/async/src/future.h b/async/src/future.h
index aa8e9be..54580ad 100644
--- a/async/src/future.h
+++ b/async/src/future.h
@@ -35,13 +35,11 @@ public:
     virtual ~FutureBase();
 
     virtual void setFinished() = 0;
-    bool isFinished() const;
+    virtual bool isFinished() const = 0;
 
 protected:
     FutureBase();
     FutureBase(const FutureBase &other);
-
-    bool mFinished;
 };
 
 template<typename T>
@@ -58,7 +56,7 @@ class FutureGeneric : public FutureBase
 public:
     void setFinished()
     {
-        mFinished = true;
+        d->finished = true;
         for (auto watcher : d->watchers) {
             if (watcher) {
                 watcher->futureReadyCallback();
@@ -66,6 +64,11 @@ public:
         }
     }
 
+    bool isFinished() const
+    {
+        return d->finished;
+    }
+
     void waitForFinished()
     {
         if (isFinished()) {
@@ -93,10 +96,12 @@ protected:
     class Private : public QSharedData
     {
     public:
+        Private() : QSharedData(), finished(false) {}
         typename std::conditional<std::is_void<T>::value, int /* dummy */, T>::type
         value;
 
         QVector<QPointer<FutureWatcher<T>>> watchers;
+        bool finished;
     };
 
     QExplicitlySharedDataPointer<Private> d;