Skip to content
Snippets Groups Projects
Commit c96151bf authored by Jan Tattermusch's avatar Jan Tattermusch
Browse files

Merge pull request #6561 from vjpai/ytpo

De-:poop:ify code
parents 4e841829 b4cb2491
No related branches found
No related tags found
No related merge requests found
...@@ -413,7 +413,7 @@ bool InteropClient::DoRequestStreaming() { ...@@ -413,7 +413,7 @@ bool InteropClient::DoRequestStreaming() {
} }
bool InteropClient::DoResponseStreaming() { bool InteropClient::DoResponseStreaming() {
gpr_log(GPR_DEBUG, "Receiving response steaming rpc ..."); gpr_log(GPR_DEBUG, "Receiving response streaming rpc ...");
ClientContext context; ClientContext context;
StreamingOutputCallRequest request; StreamingOutputCallRequest request;
...@@ -465,7 +465,7 @@ bool InteropClient::DoResponseCompressedStreaming() { ...@@ -465,7 +465,7 @@ bool InteropClient::DoResponseCompressedStreaming() {
CompressionType_Name(compression_types[j]).c_str(), CompressionType_Name(compression_types[j]).c_str(),
PayloadType_Name(payload_types[i]).c_str()); PayloadType_Name(payload_types[i]).c_str());
gpr_log(GPR_DEBUG, "Receiving response steaming rpc %s.", log_suffix); gpr_log(GPR_DEBUG, "Receiving response streaming rpc %s.", log_suffix);
request.set_response_type(payload_types[i]); request.set_response_type(payload_types[i]);
request.set_response_compression(compression_types[j]); request.set_response_compression(compression_types[j]);
...@@ -544,7 +544,7 @@ bool InteropClient::DoResponseCompressedStreaming() { ...@@ -544,7 +544,7 @@ bool InteropClient::DoResponseCompressedStreaming() {
} }
bool InteropClient::DoResponseStreamingWithSlowConsumer() { bool InteropClient::DoResponseStreamingWithSlowConsumer() {
gpr_log(GPR_DEBUG, "Receiving response steaming rpc with slow consumer ..."); gpr_log(GPR_DEBUG, "Receiving response streaming rpc with slow consumer ...");
ClientContext context; ClientContext context;
StreamingOutputCallRequest request; StreamingOutputCallRequest request;
...@@ -677,7 +677,7 @@ bool InteropClient::DoPingPong() { ...@@ -677,7 +677,7 @@ bool InteropClient::DoPingPong() {
} }
bool InteropClient::DoCancelAfterBegin() { bool InteropClient::DoCancelAfterBegin() {
gpr_log(GPR_DEBUG, "Sending request steaming rpc ..."); gpr_log(GPR_DEBUG, "Sending request streaming rpc ...");
ClientContext context; ClientContext context;
StreamingInputCallRequest request; StreamingInputCallRequest request;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment