A model stress test to try to crash the result emitter when used with

threads.

1 files changed, 16 insertions, 10 deletions

diff --git a/common/asyncutils.h b/common/asyncutils.h
index 2cf010e..6cbcee8 100644
--- a/common/asyncutils.h
+++ b/common/asyncutils.h
@@ -25,17 +25,23 @@
 
 namespace async {
 template <typename T>
-KAsync::Job<T> run(const std::function<T()> &f)
+KAsync::Job<T> run(const std::function<T()> &f, bool runAsync = true)
 {
-    return KAsync::start<T>([f](KAsync::Future<T> &future) {
-        auto result = QtConcurrent::run(f);
-        auto watcher = new QFutureWatcher<T>;
-        watcher->setFuture(result);
-        QObject::connect(watcher, &QFutureWatcher<T>::finished, watcher, [&future, watcher]() {
-            future.setValue(watcher->future().result());
-            delete watcher;
-            future.setFinished();
+    if (runAsync) {
+        return KAsync::start<T>([f](KAsync::Future<T> &future) {
+            auto result = QtConcurrent::run(f);
+            auto watcher = new QFutureWatcher<T>;
+            watcher->setFuture(result);
+            QObject::connect(watcher, &QFutureWatcher<T>::finished, watcher, [&future, watcher]() {
+                future.setValue(watcher->future().result());
+                delete watcher;
+                future.setFinished();
+            });
         });
-    });
+    } else {
+        return KAsync::syncStart<T>([f]() {
+            return f();
+        });
+    }
 }
 }