aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/actors/helpers/flow_controlled_queue.cpp
diff options
context:
space:
mode:
authorivanmorozov <ivanmorozov@yandex-team.com>2022-10-18 16:56:45 +0300
committerivanmorozov <ivanmorozov@yandex-team.com>2022-10-18 16:56:45 +0300
commitdafdfd006bf375ec29372727503fd7d707c7d9dd (patch)
tree273f9393d7fc5cbde017f704a6faff0f9ccc0c43 /library/cpp/actors/helpers/flow_controlled_queue.cpp
parent55db30fd8a67561f343be996098d7c29de84f3cd (diff)
downloadydb-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.cpp8
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))