diff options
author | Alexey Efimov <xeno@prnwatch.com> | 2022-02-10 16:49:42 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:49:42 +0300 |
commit | 0fd1998e1b2369f50fb694556f817d3c7fef10c8 (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/actors/helpers | |
parent | 26e0e4fb5e5cd6b4d7f4c21f9fcd7978891bf946 (diff) | |
download | ydb-0fd1998e1b2369f50fb694556f817d3c7fef10c8.tar.gz |
Restoring authorship annotation for Alexey Efimov <xeno@prnwatch.com>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/actors/helpers')
-rw-r--r-- | library/cpp/actors/helpers/future_callback.h | 62 | ||||
-rw-r--r-- | library/cpp/actors/helpers/ya.make | 2 |
2 files changed, 32 insertions, 32 deletions
diff --git a/library/cpp/actors/helpers/future_callback.h b/library/cpp/actors/helpers/future_callback.h index ecaf25d144b..8ca0d99fdae 100644 --- a/library/cpp/actors/helpers/future_callback.h +++ b/library/cpp/actors/helpers/future_callback.h @@ -1,33 +1,33 @@ -#pragma once - +#pragma once + #include <library/cpp/actors/core/actor.h> #include <library/cpp/actors/core/hfunc.h> - -namespace NActors { - -template <typename EventType> -struct TActorFutureCallback : TActor<TActorFutureCallback<EventType>> { - using TCallback = std::function<void(TAutoPtr<TEventHandle<EventType>>&)>; - using TBase = TActor<TActorFutureCallback<EventType>>; - TCallback Callback; - - static constexpr IActor::EActivityType ActorActivityType() { - return IActor::ACTOR_FUTURE_CALLBACK; - } - - TActorFutureCallback(TCallback&& callback) - : TBase(&TActorFutureCallback::StateWaitForEvent) - , Callback(std::move(callback)) - {} - - STRICT_STFUNC(StateWaitForEvent, - HFunc(EventType, Handle) - ) - - void Handle(typename EventType::TPtr ev, const TActorContext& ctx) { - Callback(ev); - TBase::Die(ctx); - } -}; - -} // NActors + +namespace NActors { + +template <typename EventType> +struct TActorFutureCallback : TActor<TActorFutureCallback<EventType>> { + using TCallback = std::function<void(TAutoPtr<TEventHandle<EventType>>&)>; + using TBase = TActor<TActorFutureCallback<EventType>>; + TCallback Callback; + + static constexpr IActor::EActivityType ActorActivityType() { + return IActor::ACTOR_FUTURE_CALLBACK; + } + + TActorFutureCallback(TCallback&& callback) + : TBase(&TActorFutureCallback::StateWaitForEvent) + , Callback(std::move(callback)) + {} + + STRICT_STFUNC(StateWaitForEvent, + HFunc(EventType, Handle) + ) + + void Handle(typename EventType::TPtr ev, const TActorContext& ctx) { + Callback(ev); + TBase::Die(ctx); + } +}; + +} // NActors diff --git a/library/cpp/actors/helpers/ya.make b/library/cpp/actors/helpers/ya.make index e7302cea096..d8771179de8 100644 --- a/library/cpp/actors/helpers/ya.make +++ b/library/cpp/actors/helpers/ya.make @@ -7,7 +7,7 @@ SRCS( activeactors.h flow_controlled_queue.cpp flow_controlled_queue.h - future_callback.h + future_callback.h mon_histogram_helper.h selfping_actor.cpp ) |