Merge pull request #17655 from yashykt/callbackwriteoptions

Use the WriteOptions in Client Callback API
6 years ago · 1730c06c48
parent 3864ad9aff 361acdbed1
commit 1730c06c48
1 changed files with 4 additions and 4 deletions
--- 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_);