diff options
author | heretic <heretic@yandex-team.ru> | 2022-02-10 16:45:46 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:45:46 +0300 |
commit | 81eddc8c0b55990194e112b02d127b87d54164a9 (patch) | |
tree | 9142afc54d335ea52910662635b898e79e192e49 /contrib/libs/grpc/test/cpp/end2end/interceptors_util.h | |
parent | 397cbe258b9e064f49c4ca575279f02f39fef76e (diff) | |
download | ydb-81eddc8c0b55990194e112b02d127b87d54164a9.tar.gz |
Restoring authorship annotation for <heretic@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'contrib/libs/grpc/test/cpp/end2end/interceptors_util.h')
-rw-r--r-- | contrib/libs/grpc/test/cpp/end2end/interceptors_util.h | 40 |
1 files changed, 20 insertions, 20 deletions
diff --git a/contrib/libs/grpc/test/cpp/end2end/interceptors_util.h b/contrib/libs/grpc/test/cpp/end2end/interceptors_util.h index f332e87762..c95170bbbc 100644 --- a/contrib/libs/grpc/test/cpp/end2end/interceptors_util.h +++ b/contrib/libs/grpc/test/cpp/end2end/interceptors_util.h @@ -102,16 +102,16 @@ class EchoTestServiceStreamingImpl : public EchoTestService::Service { public: ~EchoTestServiceStreamingImpl() override {} - Status Echo(ServerContext* context, const EchoRequest* request, - EchoResponse* response) override { - auto client_metadata = context->client_metadata(); - for (const auto& pair : client_metadata) { - context->AddTrailingMetadata(ToString(pair.first), ToString(pair.second)); - } - response->set_message(request->message()); - return Status::OK; - } - + Status Echo(ServerContext* context, const EchoRequest* request, + EchoResponse* response) override { + auto client_metadata = context->client_metadata(); + for (const auto& pair : client_metadata) { + context->AddTrailingMetadata(ToString(pair.first), ToString(pair.second)); + } + response->set_message(request->message()); + return Status::OK; + } + Status BidiStream( ServerContext* context, grpc::ServerReaderWriter<EchoResponse, EchoRequest>* stream) override { @@ -138,7 +138,7 @@ class EchoTestServiceStreamingImpl : public EchoTestService::Service { } EchoRequest req; - string response_str = ""; + string response_str = ""; while (reader->Read(&req)) { response_str += req.message(); } @@ -172,20 +172,20 @@ void MakeServerStreamingCall(const std::shared_ptr<Channel>& channel); void MakeBidiStreamingCall(const std::shared_ptr<Channel>& channel); -void MakeAsyncCQCall(const std::shared_ptr<Channel>& channel); - -void MakeAsyncCQClientStreamingCall(const std::shared_ptr<Channel>& channel); - -void MakeAsyncCQServerStreamingCall(const std::shared_ptr<Channel>& channel); - -void MakeAsyncCQBidiStreamingCall(const std::shared_ptr<Channel>& channel); - +void MakeAsyncCQCall(const std::shared_ptr<Channel>& channel); + +void MakeAsyncCQClientStreamingCall(const std::shared_ptr<Channel>& channel); + +void MakeAsyncCQServerStreamingCall(const std::shared_ptr<Channel>& channel); + +void MakeAsyncCQBidiStreamingCall(const std::shared_ptr<Channel>& channel); + void MakeCallbackCall(const std::shared_ptr<Channel>& channel); bool CheckMetadata(const std::multimap<grpc::string_ref, grpc::string_ref>& map, const string& key, const string& value); -bool CheckMetadata(const std::multimap<TString, TString>& map, +bool CheckMetadata(const std::multimap<TString, TString>& map, const string& key, const string& value); std::vector<std::unique_ptr<experimental::ClientInterceptorFactoryInterface>> |