File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed
ydb/core/grpc_services/query Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -211,7 +211,7 @@ class TExecuteQueryRPC : public TActorBootstrapped<TExecuteQueryRPC> {
211211 HFunc (TRpcServices::TEvGrpcNextReply, Handle);
212212 HFunc (NKqp::TEvKqpExecuter::TEvStreamData, Handle);
213213 HFunc (NKqp::TEvKqp::TEvQueryResponse, Handle);
214- HFunc (NKikimr::NGRpcService::TEvSubscribeGrpcCancel, Handle);
214+ hFunc (NKikimr::NGRpcService::TEvSubscribeGrpcCancel, Handle);
215215 default :
216216 UnexpectedEvent (__func__, ev);
217217 }
@@ -278,8 +278,9 @@ class TExecuteQueryRPC : public TActorBootstrapped<TExecuteQueryRPC> {
278278 }
279279 }
280280
281- void Handle (NKikimr::NGRpcService::TEvSubscribeGrpcCancel::TPtr&, const TActorContext&) {
282- // Ignore event now
281+ void Handle (NKikimr::NGRpcService::TEvSubscribeGrpcCancel::TPtr& ev) {
282+ auto as = TActivationContext::ActorSystem ();
283+ PassSubscription (ev->Get (), Request_.get (), as);
283284 }
284285
285286 void Handle (TEvents::TEvWakeup::TPtr& ev, const TActorContext& ctx) {
You can’t perform that action at this time.
0 commit comments