@@ -22,12 +22,8 @@ namespace {
2222
2323class TDqChannelStorage : public IDqChannelStorage {
2424public:
25- TDqChannelStorage (TTxId txId, ui64 channelId, TWakeUpCallback&& wakeUp, TActorSystem* actorSystem, bool isConcurrent) {
26- if (isConcurrent) {
27- SelfActor_ = CreateDqChannelStorageActor (txId, channelId, std::move (wakeUp), actorSystem);
28- } else {
29- SelfActor_ = CreateDqChannelStorageActor (txId, channelId, std::move (wakeUp), actorSystem);
30- }
25+ TDqChannelStorage (TTxId txId, ui64 channelId, TWakeUpCallback&& wakeUp, TActorSystem* actorSystem) {
26+ SelfActor_ = CreateDqChannelStorageActor (txId, channelId, std::move (wakeUp), actorSystem);
3127 TlsActivationContext->AsActorContext ().RegisterWithSameMailbox (SelfActor_->GetActor ());
3228 }
3329
@@ -59,7 +55,7 @@ class TDqChannelStorage : public IDqChannelStorage {
5955
6056IDqChannelStorage::TPtr CreateDqChannelStorage (TTxId txId, ui64 channelId, IDqChannelStorage::TWakeUpCallback wakeUp, TActorSystem* actorSystem)
6157{
62- return new TDqChannelStorage (txId, channelId, std::move (wakeUp), actorSystem, false /* isConcurrent */ );
58+ return new TDqChannelStorage (txId, channelId, std::move (wakeUp), actorSystem);
6359}
6460
6561} // namespace NYql::NDq
0 commit comments