Async: Nested job error propagation.

1 files changed, 5 insertions, 1 deletions

diff --git a/async/src/async.h b/async/src/async.h
index d6a74c0..18b5979 100644
--- a/async/src/async.h
+++ b/async/src/async.h
@@ -514,7 +514,11 @@ private:
                                  // copy by value is const
                                  auto outFuture = future;
                                  Async::detail::copyFutureValue(watcher->future(), outFuture);
-                                 outFuture.setFinished();
+                                 if (watcher->future().errorCode()) {
+                                     outFuture.setError(watcher->future().errorCode(), watcher->future().errorMessage());
+                                 } else {
+                                     outFuture.setFinished();
+                                 }
                                  delete watcher;
                              });
             watcher->setFuture(job.exec(in ...));