diff options
author | Daniil Cherednik <dcherednik@ydb.tech> | 2023-08-25 09:14:00 +0000 |
---|---|---|
committer | Daniil Cherednik <dcherednik@ydb.tech> | 2023-08-25 09:14:00 +0000 |
commit | 1aea989538126dcf9bb99aa87313ba942e679e7b (patch) | |
tree | 5f89fae597bbf8cfaf58c56fd2313d1896a956bb /library/cpp/grpc/client/grpc_client_low.h | |
parent | 41effae1b14cbd91927d4d7746c935f773ee87ef (diff) | |
download | ydb-1aea989538126dcf9bb99aa87313ba942e679e7b.tar.gz |
Create stable-23-3 branch
x-stable-origin-commit: 3224c68a1e19d5457dc64c1c4f3260f7cd718558
Diffstat (limited to 'library/cpp/grpc/client/grpc_client_low.h')
-rw-r--r-- | library/cpp/grpc/client/grpc_client_low.h | 13 |
1 files changed, 9 insertions, 4 deletions
diff --git a/library/cpp/grpc/client/grpc_client_low.h b/library/cpp/grpc/client/grpc_client_low.h index bf0f8e0f9f..037463cb78 100644 --- a/library/cpp/grpc/client/grpc_client_low.h +++ b/library/cpp/grpc/client/grpc_client_low.h @@ -387,16 +387,21 @@ private: bool Replied_ = false; }; -template<class TResponse> -class IStreamRequestReadProcessor : public TThrRefBase { +class IStreamRequestCtrl : public TThrRefBase { public: - using TPtr = TIntrusivePtr<IStreamRequestReadProcessor>; - using TReadCallback = std::function<void(TGrpcStatus&&)>; + using TPtr = TIntrusivePtr<IStreamRequestCtrl>; /** * Asynchronously cancel the request */ virtual void Cancel() = 0; +}; + +template<class TResponse> +class IStreamRequestReadProcessor : public IStreamRequestCtrl { +public: + using TPtr = TIntrusivePtr<IStreamRequestReadProcessor>; + using TReadCallback = std::function<void(TGrpcStatus&&)>; /** * Scheduled initial server metadata read from the stream |