diff options
author | ivanmorozov <ivanmorozov@yandex-team.com> | 2022-10-18 16:56:45 +0300 |
---|---|---|
committer | ivanmorozov <ivanmorozov@yandex-team.com> | 2022-10-18 16:56:45 +0300 |
commit | dafdfd006bf375ec29372727503fd7d707c7d9dd (patch) | |
tree | 273f9393d7fc5cbde017f704a6faff0f9ccc0c43 /library/cpp/actors/helpers/flow_controlled_queue.cpp | |
parent | 55db30fd8a67561f343be996098d7c29de84f3cd (diff) | |
download | ydb-dafdfd006bf375ec29372727503fd7d707c7d9dd.tar.gz |
actors object model
Diffstat (limited to 'library/cpp/actors/helpers/flow_controlled_queue.cpp')
-rw-r--r-- | library/cpp/actors/helpers/flow_controlled_queue.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/library/cpp/actors/helpers/flow_controlled_queue.cpp b/library/cpp/actors/helpers/flow_controlled_queue.cpp index d75cc540236..41e0944c628 100644 --- a/library/cpp/actors/helpers/flow_controlled_queue.cpp +++ b/library/cpp/actors/helpers/flow_controlled_queue.cpp @@ -12,7 +12,7 @@ namespace NActors { class TFlowControlledRequestQueue; -class TFlowControlledRequestActor : public IActor { +class TFlowControlledRequestActor : public IActorCallback { TFlowControlledRequestQueue * const QueueActor; void HandleReply(TAutoPtr<IEventHandle> &ev); @@ -24,7 +24,7 @@ public: const ui64 StartCounter; TFlowControlledRequestActor(ui32 activity, TFlowControlledRequestQueue *queue, TActorId source, ui64 cookie, ui32 flags) - : IActor(static_cast<TReceiveFunc>(&TFlowControlledRequestActor::StateWait), activity) + : IActorCallback(static_cast<TReceiveFunc>(&TFlowControlledRequestActor::StateWait), activity) , QueueActor(queue) , Source(source) , Cookie(cookie) @@ -48,7 +48,7 @@ public: using IActor::PassAway; }; -class TFlowControlledRequestQueue : public IActor { +class TFlowControlledRequestQueue : public IActorCallback { const TActorId Target; const TFlowControlledQueueConfig Config; @@ -154,7 +154,7 @@ class TFlowControlledRequestQueue : public IActor { } public: TFlowControlledRequestQueue(TActorId target, ui32 activity, const TFlowControlledQueueConfig &config) - : IActor(static_cast<TReceiveFunc>(&TFlowControlledRequestQueue::StateWork), activity) + : IActorCallback(static_cast<TReceiveFunc>(&TFlowControlledRequestQueue::StateWork), activity) , Target(target) , Config(config) , MinimalSeenLatency(TDuration::Seconds(1)) |