aboutsummaryrefslogtreecommitdiffhomepage
path: root/include/grpc++/stream.h
diff options
context:
space:
mode:
authorGravatar Yang Gao <yangg@google.com>2015-03-03 09:48:06 -0800
committerGravatar Yang Gao <yangg@google.com>2015-03-03 09:48:06 -0800
commit7694c35d5f9c85ea844755d35f7d78d76e38348c (patch)
treee34309aa27b3519ed4885454751c1a1e50735a52 /include/grpc++/stream.h
parent4e233a1a4653699bda751ef38923c7d755093d2c (diff)
Global replace google::protobuf::Message with grpc::protobuf::Message, all tests passed
Diffstat (limited to 'include/grpc++/stream.h')
-rw-r--r--include/grpc++/stream.h12
1 files changed, 6 insertions, 6 deletions
diff --git a/include/grpc++/stream.h b/include/grpc++/stream.h
index d95a379757..7625bcc38d 100644
--- a/include/grpc++/stream.h
+++ b/include/grpc++/stream.h
@@ -88,7 +88,7 @@ class ClientReader GRPC_FINAL : public ClientStreamingInterface,
public:
// Blocking create a stream and write the first request out.
ClientReader(ChannelInterface* channel, const RpcMethod& method,
- ClientContext* context, const google::protobuf::Message& request)
+ ClientContext* context, const grpc::protobuf::Message& request)
: context_(context), call_(channel->CreateCall(method, context, &cq_)) {
CallOpBuffer buf;
buf.AddSendInitialMetadata(&context->send_initial_metadata_);
@@ -142,7 +142,7 @@ class ClientWriter GRPC_FINAL : public ClientStreamingInterface,
public:
// Blocking create a stream.
ClientWriter(ChannelInterface* channel, const RpcMethod& method,
- ClientContext* context, google::protobuf::Message* response)
+ ClientContext* context, grpc::protobuf::Message* response)
: context_(context),
response_(response),
call_(channel->CreateCall(method, context, &cq_)) {
@@ -179,7 +179,7 @@ class ClientWriter GRPC_FINAL : public ClientStreamingInterface,
private:
ClientContext* context_;
- google::protobuf::Message* const response_;
+ grpc::protobuf::Message* const response_;
CompletionQueue cq_;
Call call_;
};
@@ -386,7 +386,7 @@ class ClientAsyncReader GRPC_FINAL : public ClientAsyncStreamingInterface,
// Create a stream and write the first request out.
ClientAsyncReader(ChannelInterface* channel, CompletionQueue* cq,
const RpcMethod& method, ClientContext* context,
- const google::protobuf::Message& request, void* tag)
+ const grpc::protobuf::Message& request, void* tag)
: context_(context), call_(channel->CreateCall(method, context, cq)) {
init_buf_.Reset(tag);
init_buf_.AddSendInitialMetadata(&context->send_initial_metadata_);
@@ -436,7 +436,7 @@ class ClientAsyncWriter GRPC_FINAL : public ClientAsyncStreamingInterface,
public:
ClientAsyncWriter(ChannelInterface* channel, CompletionQueue* cq,
const RpcMethod& method, ClientContext* context,
- google::protobuf::Message* response, void* tag)
+ grpc::protobuf::Message* response, void* tag)
: context_(context),
response_(response),
call_(channel->CreateCall(method, context, cq)) {
@@ -477,7 +477,7 @@ class ClientAsyncWriter GRPC_FINAL : public ClientAsyncStreamingInterface,
private:
ClientContext* context_;
- google::protobuf::Message* const response_;
+ grpc::protobuf::Message* const response_;
Call call_;
CallOpBuffer init_buf_;
CallOpBuffer meta_buf_;