diff options
| author |  Yash Tibrewal <yashkt@google.com> | 2019-01-07 17:33:16 -0800 |
|---|---|---|
| committer | Yash Tibrewal <yashkt@google.com> | 2019-01-07 17:33:16 -0800 |
| commit | 361acdbed1805dd9f313deb4bc92dbd5e8612a7b (patch) | |
| tree | 46dd14c327aabe65390557da5b9f554a4f39b96e /include | |
| parent | 8dcda4dc36aa4e4d3a4c46023f6470b4c1ec7bca (diff) | |
Use the WriteOptions in Client Callback API
Diffstat (limited to 'include')
| -rw-r--r-- | include/grpcpp/impl/codegen/client_callback.h | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/include/grpcpp/impl/codegen/client_callback.h b/include/grpcpp/impl/codegen/client_callback.h index c20e845810..52bcea9970 100644 --- a/include/grpcpp/impl/codegen/client_callback.h +++ b/include/grpcpp/impl/codegen/client_callback.h @@ -340,13 +340,13 @@ class ClientCallbackReaderWriterImpl context_->initial_metadata_flags()); start_corked_ = false; } - // TODO(vjpai): don't assert - GPR_CODEGEN_ASSERT(write_ops_.SendMessagePtr(msg).ok()); if (options.is_last_message()) { options.set_buffer_hint(); write_ops_.ClientSendClose(); } + // TODO(vjpai): don't assert + GPR_CODEGEN_ASSERT(write_ops_.SendMessagePtr(msg, options).ok()); callbacks_outstanding_++; if (started_) { call_.PerformOps(&write_ops_); @@ -649,13 +649,13 @@ class ClientCallbackWriterImpl context_->initial_metadata_flags()); start_corked_ = false; } - // TODO(vjpai): don't assert - GPR_CODEGEN_ASSERT(write_ops_.SendMessagePtr(msg).ok()); if (options.is_last_message()) { options.set_buffer_hint(); write_ops_.ClientSendClose(); } + // TODO(vjpai): don't assert + GPR_CODEGEN_ASSERT(write_ops_.SendMessagePtr(msg, options).ok()); callbacks_outstanding_++; if (started_) { call_.PerformOps(&write_ops_); |