Resolved potential deadlock

When trying to reply to a mail from kube we ran into a deadlock.
The initial result callback is called from the main thread, and that can
thus directly lead to destruction of the emitter.

1 files changed, 14 insertions, 6 deletions

diff --git a/tests/clientapitest.cpp b/tests/clientapitest.cpp
index da52afb..3955ebd 100644
--- a/tests/clientapitest.cpp
+++ b/tests/clientapitest.cpp
@@ -12,6 +12,12 @@
 #include "asyncutils.h"
 
 template <typename T>
+struct Result {
+    QSharedPointer<T> parent;
+    bool fetchedAll;
+};
+
+template <typename T>
 class TestDummyResourceFacade : public Sink::StoreFacade<T>
 {
 public:
@@ -68,7 +74,7 @@ public:
         auto emitter = resultProvider->emitter();
 
         resultProvider->setFetcher([query, resultProvider, this, ctx](const typename T::Ptr &parent) {
-            async::run<int>([=] {
+            async::run<Result<T>>([=] {
                 if (parent) {
                     SinkTraceCtx(ctx) << "Running the fetcher " << parent->identifier();
                 } else {
@@ -90,14 +96,16 @@ public:
                             SinkTraceCtx(ctx) << "Aborting early after " << count << "results.";
                             offset = i + 1;
                             bool fetchedAll = (i + 1 >= results.size());
-                            resultProvider->initialResultSetComplete(parent, fetchedAll);
-                            return 0;
+                            return Result<T>{parent, fetchedAll};
                         }
                     }
                 }
-                resultProvider->initialResultSetComplete(parent, true);
-                return 0;
-            }, runAsync).exec();
+                return Result<T>{parent, true};
+            }, runAsync)
+            .then([=] (const Result<T> &r) {
+                resultProvider->initialResultSetComplete(r.parent, r.fetchedAll);
+            })
+            .exec();
         });
         auto job = KAsync::start([query, resultProvider]() {});
         mResultProvider = resultProvider.data();