aboutsummaryrefslogtreecommitdiffhomepage
path: root/include/grpc++/stream.h
diff options
context:
space:
mode:
authorGravatar Craig Tiller <ctiller@google.com>2015-08-17 13:23:14 -0700
committerGravatar Craig Tiller <ctiller@google.com>2015-08-17 13:23:14 -0700
commit8f7bff7d48129e577f972815afcc9f32c78d258b (patch)
treec2f278fdefc6348a0ba2ba413b13e613115fdc8c /include/grpc++/stream.h
parentd067c263b250657891de4ad96ae51249435c6066 (diff)
parent2194cd8fd4d53a3333fbd0e7bc938e22210d23d2 (diff)
Merge github.com:grpc/grpc into y12kdm3
Diffstat (limited to 'include/grpc++/stream.h')
-rw-r--r--include/grpc++/stream.h11
1 files changed, 5 insertions, 6 deletions
diff --git a/include/grpc++/stream.h b/include/grpc++/stream.h
index bc0c3c0f3b..4bffaffb40 100644
--- a/include/grpc++/stream.h
+++ b/include/grpc++/stream.h
@@ -85,9 +85,7 @@ class WriterInterface {
// Returns false when the stream has been closed.
virtual bool Write(const W& msg, const WriteOptions& options) = 0;
- inline bool Write(const W& msg) {
- return Write(msg, WriteOptions());
- }
+ inline bool Write(const W& msg) { return Write(msg, WriteOptions()); }
};
template <class R>
@@ -640,9 +638,8 @@ class ServerAsyncReader GRPC_FINAL : public ServerAsyncStreamingInterface,
}
// The response is dropped if the status is not OK.
if (status.ok()) {
- finish_ops_.ServerSendStatus(
- ctx_->trailing_metadata_,
- finish_ops_.SendMessage(msg));
+ finish_ops_.ServerSendStatus(ctx_->trailing_metadata_,
+ finish_ops_.SendMessage(msg));
} else {
finish_ops_.ServerSendStatus(ctx_->trailing_metadata_, status);
}
@@ -764,6 +761,8 @@ class ServerAsyncReaderWriter GRPC_FINAL : public ServerAsyncStreamingInterface,
}
private:
+ friend class ::grpc::Server;
+
void BindCall(Call* call) GRPC_OVERRIDE { call_ = *call; }
Call call_;