File indexing completed on 2024-05-12 05:29:23

 /*
  *   SPDX-FileCopyrightText: 2014-2016 Ivan Cukic <ivan.cukic@kde.org>
  *
  *   SPDX-License-Identifier: GPL-2.0-only OR GPL-3.0-only OR LicenseRef-KDE-Accepted-GPL
  */
 
 #pragma once
 
 #include <QFuture>
 #include <QFutureWatcher>
 
 #include "utils/optional_view.h"
 // #include <boost/optional.hpp>
 
 #ifdef ENABLE_QJSVALUE_CONTINUATION
 #include <QJSValue>
 #endif
 
 namespace kamd
 {
 namespace utils
 {
 namespace detail
 { //_
 #ifdef ENABLE_QJSVALUE_CONTINUATION
 inline void test_continuation(const QJSValue &continuation)
 {
     if (!continuation.isCallable()) {
         qCWarning(KAMD_LOG_RESOURCES) << "Passed handler is not callable: " << continuation.toString();
     }
 }
 
 template<typename _ReturnType>
 inline void pass_value(const QFuture<_ReturnType> &future, QJSValue continuation)
 {
     auto result = continuation.call({future.result()});
     if (result.isError()) {
         qCWarning(KAMD_LOG_RESOURCES) << "Handler returned this error: " << result.toString();
     }
 }
 
 inline void pass_value(const QFuture<void> &future, QJSValue continuation)
 {
     Q_UNUSED(future);
     auto result = continuation.call({});
     if (result.isError()) {
         qCWarning(KAMD_LOG_RESOURCES) << "Handler returned this error: " << result.toString();
     }
 }
 #endif
 
 template<typename _Continuation>
 inline void test_continuation(_Continuation &&continuation)
 {
     Q_UNUSED(continuation);
 }
 
 template<typename _ReturnType, typename _Continuation>
 inline void pass_value(const QFuture<_ReturnType> &future, _Continuation &&continuation)
 {
     using namespace kamd::utils;
     continuation(future.resultCount() > 0 ? make_optional_view(future.result()) : none());
 }
 
 template<typename _Continuation>
 inline void pass_value(_Continuation &&continuation)
 {
     continuation();
 }
 
 } //^ namespace detail
 
 template<typename _ReturnType, typename _Continuation>
 inline void continue_with(const QFuture<_ReturnType> &future, _Continuation &&continuation)
 {
     detail::test_continuation(continuation);
 
     auto watcher = new QFutureWatcher<_ReturnType>();
     QObject::connect(watcher, &QFutureWatcherBase::finished, [=]() mutable {
         detail::pass_value(future, continuation);
     });
 
     watcher->setFuture(future);
 }
 
 } // namespace utils
 } // namespace kamd