Skip to content

Commit

Permalink
Fixed diff 4
Browse files Browse the repository at this point in the history
  • Loading branch information
GrigoriyPA committed Dec 4, 2024
1 parent ac91800 commit 6a3d76b
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion ydb/core/fq/libs/row_dispatcher/topic_session.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,8 @@ constexpr ui64 MaxHandledEventsSize = 1000000;

class TTopicSession : public TActorBootstrapped<TTopicSession> {
private:
using TBase = TActorBootstrapped<TTopicSession>;

struct TStats {
void Add(ui64 dataSize, ui64 events) {
Bytes += dataSize;
Expand Down Expand Up @@ -363,7 +365,7 @@ void TTopicSession::Bootstrap() {
void TTopicSession::PassAway() {
LOG_ROW_DISPATCHER_DEBUG("PassAway");
StopReadSession();
TActorBootstrapped<TTopicSession>::PassAway();
TBase::PassAway();
}

void TTopicSession::SubscribeOnNextEvent() {
Expand Down

0 comments on commit 6a3d76b

Please sign in to comment.