diff options
author | uzhas <uzhas@yandex-team.ru> | 2022-02-10 16:47:06 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:47:06 +0300 |
commit | 2002caab389ddffd0e7db4d8c4db835fa4c99f83 (patch) | |
tree | 9d3448d5ba97edddf88aa69bcb138e88286e8176 /library/cpp/grpc | |
parent | 17d51d51855dc3ed663d0e31fa75d3ff5ab80702 (diff) | |
download | ydb-2002caab389ddffd0e7db4d8c4db835fa4c99f83.tar.gz |
Restoring authorship annotation for <uzhas@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/grpc')
-rw-r--r-- | library/cpp/grpc/client/grpc_client_low.h | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/library/cpp/grpc/client/grpc_client_low.h b/library/cpp/grpc/client/grpc_client_low.h index ab0a0627be..c831b1fa60 100644 --- a/library/cpp/grpc/client/grpc_client_low.h +++ b/library/cpp/grpc/client/grpc_client_low.h @@ -173,7 +173,7 @@ bool inline IsGRpcStatusGood(const TGrpcStatus& status) { return status.Ok(); } -// Response callback type - this callback will be called when request is finished +// Response callback type - this callback will be called when request is finished // (or after getting each chunk in case of streaming mode) template<typename TResponse> using TResponseCallback = std::function<void (TGrpcStatus&&, TResponse&&)>; @@ -236,8 +236,8 @@ public: using TPtr = TIntrusivePtr<TSimpleRequestProcessor>; using TAsyncRequest = TAsyncReaderPtr (TStub::*)(grpc::ClientContext*, const TRequest&, grpc::CompletionQueue*); - explicit TSimpleRequestProcessor(TResponseCallback<TResponse>&& callback) - : Callback_(std::move(callback)) + explicit TSimpleRequestProcessor(TResponseCallback<TResponse>&& callback) + : Callback_(std::move(callback)) { } ~TSimpleRequestProcessor() { @@ -316,8 +316,8 @@ public: using TPtr = TIntrusivePtr<TAdvancedRequestProcessor>; using TAsyncRequest = TAsyncReaderPtr (TStub::*)(grpc::ClientContext*, const TRequest&, grpc::CompletionQueue*); - explicit TAdvancedRequestProcessor(TAdvancedResponseCallback<TResponse>&& callback) - : Callback_(std::move(callback)) + explicit TAdvancedRequestProcessor(TAdvancedResponseCallback<TResponse>&& callback) + : Callback_(std::move(callback)) { } ~TAdvancedRequestProcessor() { @@ -1244,7 +1244,7 @@ public: */ template<typename TRequest, typename TResponse> void DoRequest(const TRequest& request, - TResponseCallback<TResponse> callback, + TResponseCallback<TResponse> callback, typename TSimpleRequestProcessor<TStub, TRequest, TResponse>::TAsyncRequest asyncRequest, const TCallMeta& metas = { }, IQueueClientContextProvider* provider = nullptr) @@ -1259,7 +1259,7 @@ public: */ template<typename TRequest, typename TResponse> void DoAdvancedRequest(const TRequest& request, - TAdvancedResponseCallback<TResponse> callback, + TAdvancedResponseCallback<TResponse> callback, typename TAdvancedRequestProcessor<TStub, TRequest, TResponse>::TAsyncRequest asyncRequest, const TCallMeta& metas = { }, IQueueClientContextProvider* provider = nullptr) |