diff options
Diffstat (limited to 'include')
-rw-r--r-- | include/grpc++/support/sync_stream.h | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/include/grpc++/support/sync_stream.h b/include/grpc++/support/sync_stream.h index daf4e367ae..aaf1a5b7cc 100644 --- a/include/grpc++/support/sync_stream.h +++ b/include/grpc++/support/sync_stream.h @@ -36,6 +36,7 @@ #include <grpc/support/log.h> #include <grpc++/channel.h> +#include <grpc++/impl/codegen/channel_interface.h> #include <grpc++/client_context.h> #include <grpc++/completion_queue.h> #include <grpc++/impl/call.h> @@ -118,7 +119,7 @@ class ClientReader GRPC_FINAL : public ClientReaderInterface<R> { public: /// Blocking create a stream and write the first request out. template <class W> - ClientReader(Channel* channel, const RpcMethod& method, + ClientReader(ChannelInterface* channel, const RpcMethod& method, ClientContext* context, const W& request) : context_(context), call_(channel->CreateCall(method, context, &cq_)) { CallOpSet<CallOpSendInitialMetadata, CallOpSendMessage, @@ -182,7 +183,7 @@ class ClientWriter : public ClientWriterInterface<W> { public: /// Blocking create a stream. template <class R> - ClientWriter(Channel* channel, const RpcMethod& method, + ClientWriter(ChannelInterface* channel, const RpcMethod& method, ClientContext* context, R* response) : context_(context), call_(channel->CreateCall(method, context, &cq_)) { finish_ops_.RecvMessage(response); @@ -248,7 +249,7 @@ template <class W, class R> class ClientReaderWriter GRPC_FINAL : public ClientReaderWriterInterface<W, R> { public: /// Blocking create a stream. - ClientReaderWriter(Channel* channel, const RpcMethod& method, + ClientReaderWriter(ChannelInterface* channel, const RpcMethod& method, ClientContext* context) : context_(context), call_(channel->CreateCall(method, context, &cq_)) { CallOpSet<CallOpSendInitialMetadata> ops; |