diff options
author | Vijay Pai <vpai@google.com> | 2019-01-08 08:15:43 -0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2019-01-08 08:15:43 -0800 |
commit | 1730c06c482e7f46f59eef254af74d03ca896955 (patch) | |
tree | d0a0c1afd871ac3c68b7d11e93c0ec60bad1d6ad /include | |
parent | 3864ad9affa555b4417462d5f32048133233083e (diff) | |
parent | 361acdbed1805dd9f313deb4bc92dbd5e8612a7b (diff) |
Merge pull request #17655 from yashykt/callbackwriteoptions
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_); |