From 22d92781ba2a10b7fb5b977b7d1a5c40ff53885f Mon Sep 17 00:00:00 2001
From: Alexey Borzenkov <snaury@yandex-team.ru>
Date: Thu, 10 Feb 2022 16:47:41 +0300
Subject: Restoring authorship annotation for Alexey Borzenkov
<snaury@yandex-team.ru>. Commit 1 of 2.
---
library/cpp/threading/future/core/future-inl.h | 8 ++++----
library/cpp/threading/future/core/future.h | 22 +++++++++++-----------
2 files changed, 15 insertions(+), 15 deletions(-)
(limited to 'library/cpp/threading/future/core')
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;
--
cgit v1.2.3