aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/threading/future/core
diff options
context:
space:
mode:
authorAlexey Borzenkov <snaury@yandex-team.ru>2022-02-10 16:47:41 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:41 +0300
commit22d92781ba2a10b7fb5b977b7d1a5c40ff53885f (patch)
tree852611fd27f734847435b37aa5b0ad5d8b1c10ac /library/cpp/threading/future/core
parent667a4ee7da2e004784b9c3cfab824a81e96f4d66 (diff)
downloadydb-22d92781ba2a10b7fb5b977b7d1a5c40ff53885f.tar.gz
Restoring authorship annotation for Alexey Borzenkov <snaury@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/threading/future/core')
-rw-r--r--library/cpp/threading/future/core/future-inl.h8
-rw-r--r--library/cpp/threading/future/core/future.h22
2 files changed, 15 insertions, 15 deletions
diff --git a/library/cpp/threading/future/core/future-inl.h b/library/cpp/threading/future/core/future-inl.h
index 5fd4296a93..506c77d4c8 100644
--- a/library/cpp/threading/future/core/future-inl.h
+++ b/library/cpp/threading/future/core/future-inl.h
@@ -619,8 +619,8 @@ namespace NThreading {
template <typename T>
template <typename F>
- inline TFuture<TFutureType<TFutureCallResult<F, T>>> TFuture<T>::Apply(F&& func) const {
- auto promise = NewPromise<TFutureType<TFutureCallResult<F, T>>>();
+ inline TFuture<TFutureType<TFutureCallResult<F, T>>> TFuture<T>::Apply(F&& func) const {
+ auto promise = NewPromise<TFutureType<TFutureCallResult<F, T>>>();
Subscribe([promise, func = std::forward<F>(func)](const TFuture<T>& future) mutable {
NImpl::SetValue(promise, [&]() { return func(future); });
});
@@ -718,8 +718,8 @@ namespace NThreading {
template <typename F>
- inline TFuture<TFutureType<TFutureCallResult<F, void>>> TFuture<void>::Apply(F&& func) const {
- auto promise = NewPromise<TFutureType<TFutureCallResult<F, void>>>();
+ inline TFuture<TFutureType<TFutureCallResult<F, void>>> TFuture<void>::Apply(F&& func) const {
+ auto promise = NewPromise<TFutureType<TFutureCallResult<F, void>>>();
Subscribe([promise, func = std::forward<F>(func)](const TFuture<void>& future) mutable {
NImpl::SetValue(promise, [&]() { return func(future); });
});
diff --git a/library/cpp/threading/future/core/future.h b/library/cpp/threading/future/core/future.h
index 2e82bb953e..00dc245d9a 100644
--- a/library/cpp/threading/future/core/future.h
+++ b/library/cpp/threading/future/core/future.h
@@ -47,20 +47,20 @@ namespace NThreading {
struct TFutureType<TFuture<T>> {
using TType = typename TFutureType<T>::TType;
};
-
- template <typename F, typename T>
- struct TFutureCallResult {
- // NOTE: separate class for msvc compatibility
- using TType = decltype(std::declval<F&>()(std::declval<const TFuture<T>&>()));
- };
+
+ template <typename F, typename T>
+ struct TFutureCallResult {
+ // NOTE: separate class for msvc compatibility
+ using TType = decltype(std::declval<F&>()(std::declval<const TFuture<T>&>()));
+ };
}
template <typename F>
using TFutureType = typename NImpl::TFutureType<F>::TType;
- template <typename F, typename T>
- using TFutureCallResult = typename NImpl::TFutureCallResult<F, T>::TType;
-
+ template <typename F, typename T>
+ using TFutureCallResult = typename NImpl::TFutureCallResult<F, T>::TType;
+
//! Type of the future/promise state identifier
class TFutureStateId;
@@ -109,7 +109,7 @@ namespace NThreading {
const TFuture<T>& NoexceptSubscribe(F&& callback) const noexcept;
template <typename F>
- TFuture<TFutureType<TFutureCallResult<F, T>>> Apply(F&& func) const;
+ TFuture<TFutureType<TFutureCallResult<F, T>>> Apply(F&& func) const;
TFuture<void> IgnoreResult() const;
@@ -164,7 +164,7 @@ namespace NThreading {
const TFuture<void>& NoexceptSubscribe(F&& callback) const noexcept;
template <typename F>
- TFuture<TFutureType<TFutureCallResult<F, void>>> Apply(F&& func) const;
+ TFuture<TFutureType<TFutureCallResult<F, void>>> Apply(F&& func) const;
template <typename R>
TFuture<R> Return(const R& value) const;