diff options
author | Craig Tiller <ctiller@google.com> | 2016-03-28 12:45:55 -0700 |
---|---|---|
committer | Craig Tiller <ctiller@google.com> | 2016-03-28 12:45:55 -0700 |
commit | c5ff781091db0cf6df282d0768102a2ea17d7e24 (patch) | |
tree | 94c9020d2c5e33caa0aa7ae5b511d5da8f450eec /include/grpc++/impl/codegen/sync_stream.h | |
parent | c757f34dc30d0f414037c0de38334a819ce9b5b5 (diff) | |
parent | 3bd96959398d0671fee3785d4b2aee6042649b15 (diff) |
Merge branch 'idempotent' into ignore_connectivity
Diffstat (limited to 'include/grpc++/impl/codegen/sync_stream.h')
-rw-r--r-- | include/grpc++/impl/codegen/sync_stream.h | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/include/grpc++/impl/codegen/sync_stream.h b/include/grpc++/impl/codegen/sync_stream.h index 5f878469ce..0eabc5fc0f 100644 --- a/include/grpc++/impl/codegen/sync_stream.h +++ b/include/grpc++/impl/codegen/sync_stream.h @@ -123,7 +123,8 @@ class ClientReader GRPC_FINAL : public ClientReaderInterface<R> { ClientContext* context, const W& request) : context_(context), call_(channel->CreateCall(method, context, &cq_)) { CallOpSet<CallOpSendInitialMetadata, CallOpSendMessage, - CallOpClientSendClose> ops; + CallOpClientSendClose> + ops; ops.SendInitialMetadata(context->send_initial_metadata_); // TODO(ctiller): don't assert GPR_CODEGEN_ASSERT(ops.SendMessage(request).ok()); @@ -235,7 +236,8 @@ class ClientWriter : public ClientWriterInterface<W> { private: ClientContext* context_; CallOpSet<CallOpRecvInitialMetadata, CallOpGenericRecvMessage, - CallOpClientRecvStatus> finish_ops_; + CallOpClientRecvStatus> + finish_ops_; CompletionQueue cq_; Call call_; }; |