diff options
| author |  Yash Tibrewal <yashkt@google.com> | 2018-10-08 19:03:33 -0700 |
|---|---|---|
| committer | Yash Tibrewal <yashkt@google.com> | 2018-10-16 14:10:02 -0700 |
| commit | 63bdf4e2363a3c55edf8ddb9d089da88c31963f2 (patch) | |
| tree | adbadc9a7d9adc34a6110360d85d958332fee8b6 /include/grpcpp/impl/codegen/client_unary_call.h | |
| parent | 5d831da9d135d7f1c58ff61bacb6e5a2787f05c9 (diff) | |
More changes for client interception
Diffstat (limited to 'include/grpcpp/impl/codegen/client_unary_call.h')
| -rw-r--r-- | include/grpcpp/impl/codegen/client_unary_call.h | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/include/grpcpp/impl/codegen/client_unary_call.h b/include/grpcpp/impl/codegen/client_unary_call.h index e4e8364e07..dad31546cc 100644 --- a/include/grpcpp/impl/codegen/client_unary_call.h +++ b/include/grpcpp/impl/codegen/client_unary_call.h @@ -52,7 +52,7 @@ class BlockingUnaryCallImpl { CompletionQueue cq(grpc_completion_queue_attributes{ GRPC_CQ_CURRENT_VERSION, GRPC_CQ_PLUCK, GRPC_CQ_DEFAULT_POLLING, nullptr}); // Pluckable completion queue - Call call(channel->CreateCall(method, context, &cq)); + call_ = std::move(channel->CreateCall(method, context, &cq)); CallOpSet<CallOpSendInitialMetadata, CallOpSendMessage, CallOpRecvInitialMetadata, CallOpRecvMessage<OutputMessage>, CallOpClientSendClose, CallOpClientRecvStatus> @@ -68,7 +68,7 @@ class BlockingUnaryCallImpl { ops.AllowNoMessage(); ops.ClientSendClose(); ops.ClientRecvStatus(context, &status_); - call.PerformOps(&ops); + call_.PerformOps(&ops); if (cq.Pluck(&ops)) { if (!ops.got_message && status_.ok()) { status_ = Status(StatusCode::UNIMPLEMENTED, @@ -82,6 +82,7 @@ class BlockingUnaryCallImpl { private: Status status_; + Call call_; }; } // namespace internal |