Add const to the condition function (ydb-platform#8644)

Author: azevaykin

ydb/core/testlib/actors/block_events.h

@@ -14,7 +14,7 @@ namespace NActors {
     template<class TEvType>
     class TBlockEvents : public std::deque<typename TEvType::TPtr> {
     public:
-        TBlockEvents(TTestActorRuntime& runtime, std::function<bool(typename TEvType::TPtr&)> condition = {})
+        TBlockEvents(TTestActorRuntime& runtime, std::function<bool(const typename TEvType::TPtr&)> condition = {})
             : Runtime(runtime)
             , Condition(std::move(condition))
             , Holder(Runtime.AddObserver<TEvType>(

ydb/core/testlib/actors/test_runtime_ut.cpp

@@ -793,7 +793,7 @@ Y_UNIT_TEST_SUITE(TActorTest) {
         auto source = runtime.Register(new TSourceActor(target), /* nodeIdx */ 1);
         runtime.EnableScheduleForActor(source);
 
-        TBlockEvents<TEvTrigger> block(runtime, [&](TEvTrigger::TPtr& ev){ return ev->GetRecipientRewrite() == target; });
+        TBlockEvents<TEvTrigger> block(runtime, [&](const TEvTrigger::TPtr& ev){ return ev->GetRecipientRewrite() == target; });
         runtime.WaitFor("blocked 3 events", [&]{ return block.size() >= 3; });
         UNIT_ASSERT_VALUES_EQUAL(block.size(), 3u);
         UNIT_ASSERT_VALUES_EQUAL(values.size(), 0u);

ydb/core/tx/datashard/datashard_ut_build_index.cpp

@@ -168,7 +168,7 @@ Y_UNIT_TEST_SUITE(TTxDataShardBuildIndexScan) {
 
         CreateShardedTableForIndex(server, sender, "/Root", "table-2", 1, false);
 
-        TBlockEvents<TEvDataShard::TEvCompactBorrowed> block(runtime, [&](TEvDataShard::TEvCompactBorrowed::TPtr& event) {
+        TBlockEvents<TEvDataShard::TEvCompactBorrowed> block(runtime, [&](const TEvDataShard::TEvCompactBorrowed::TPtr& event) {
             return runtime.FindActorName(event->Sender) == "FLAT_SCHEMESHARD_ACTOR";
         });
 

ydb/core/tx/datashard/datashard_ut_stats.cpp

@@ -443,7 +443,7 @@ Y_UNIT_TEST_SUITE(DataShardStats) {
 
         UpsertRows(server, sender);
 
-        TBlockEvents<NSharedCache::TEvResult> block(runtime, [&](NSharedCache::TEvResult::TPtr& event) {
+        TBlockEvents<NSharedCache::TEvResult> block(runtime, [&](const NSharedCache::TEvResult::TPtr& event) {
             return runtime.FindActorName(event->GetRecipientRewrite()) == "DATASHARD_STATS_BUILDER";
         });