|
|
@ -85,9 +85,9 @@ class ClientReader final : public ClientStreamingInterface, |
|
|
|
public ReaderInterface<R> { |
|
|
|
public ReaderInterface<R> { |
|
|
|
public: |
|
|
|
public: |
|
|
|
// Blocking create a stream and write the first request out.
|
|
|
|
// Blocking create a stream and write the first request out.
|
|
|
|
explicit ClientReader(ChannelInterface *channel, const RpcMethod &method, |
|
|
|
ClientReader(ChannelInterface *channel, const RpcMethod &method, |
|
|
|
ClientContext *context, |
|
|
|
ClientContext *context, |
|
|
|
const google::protobuf::Message &request) |
|
|
|
const google::protobuf::Message &request) |
|
|
|
: call_(channel->CreateCall(method, context, &cq_)) { |
|
|
|
: call_(channel->CreateCall(method, context, &cq_)) { |
|
|
|
CallOpBuffer buf; |
|
|
|
CallOpBuffer buf; |
|
|
|
buf.AddSendMessage(request); |
|
|
|
buf.AddSendMessage(request); |
|
|
|