|
|
|
@ -26,6 +26,7 @@ |
|
|
|
|
|
|
|
|
|
#include "src/proto/grpc/testing/compiler_test.pb.h" |
|
|
|
|
|
|
|
|
|
#include <functional> |
|
|
|
|
#include <grpcpp/impl/codegen/async_generic_service.h> |
|
|
|
|
#include <grpcpp/impl/codegen/async_stream.h> |
|
|
|
|
#include <grpcpp/impl/codegen/async_unary_call.h> |
|
|
|
@ -105,6 +106,22 @@ class ServiceA final { |
|
|
|
|
return std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< ::grpc::testing::Request, ::grpc::testing::Response>>(PrepareAsyncMethodA4Raw(context, cq)); |
|
|
|
|
} |
|
|
|
|
// Method A4 trailing comment 1 |
|
|
|
|
class experimental_async_interface { |
|
|
|
|
public: |
|
|
|
|
// MethodA1 leading comment 1 |
|
|
|
|
virtual void MethodA1(::grpc::ClientContext* context, const ::grpc::testing::Request* request, ::grpc::testing::Response* response, std::function<void(::grpc::Status)>) = 0; |
|
|
|
|
// MethodA1 trailing comment 1 |
|
|
|
|
// MethodA2 detached leading comment 1 |
|
|
|
|
// |
|
|
|
|
// Method A2 leading comment 1 |
|
|
|
|
// Method A2 leading comment 2 |
|
|
|
|
// MethodA2 trailing comment 1 |
|
|
|
|
// Method A3 leading comment 1 |
|
|
|
|
// Method A3 trailing comment 1 |
|
|
|
|
// Method A4 leading comment 1 |
|
|
|
|
// Method A4 trailing comment 1 |
|
|
|
|
}; |
|
|
|
|
virtual class experimental_async_interface* experimental_async() { return nullptr; } |
|
|
|
|
private: |
|
|
|
|
virtual ::grpc::ClientAsyncResponseReaderInterface< ::grpc::testing::Response>* AsyncMethodA1Raw(::grpc::ClientContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq) = 0; |
|
|
|
|
virtual ::grpc::ClientAsyncResponseReaderInterface< ::grpc::testing::Response>* PrepareAsyncMethodA1Raw(::grpc::ClientContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq) = 0; |
|
|
|
@ -155,9 +172,21 @@ class ServiceA final { |
|
|
|
|
std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::grpc::testing::Request, ::grpc::testing::Response>> PrepareAsyncMethodA4(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { |
|
|
|
|
return std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::grpc::testing::Request, ::grpc::testing::Response>>(PrepareAsyncMethodA4Raw(context, cq)); |
|
|
|
|
} |
|
|
|
|
class experimental_async final : |
|
|
|
|
public StubInterface::experimental_async_interface { |
|
|
|
|
public: |
|
|
|
|
void MethodA1(::grpc::ClientContext* context, const ::grpc::testing::Request* request, ::grpc::testing::Response* response, std::function<void(::grpc::Status)>) override; |
|
|
|
|
private: |
|
|
|
|
friend class Stub; |
|
|
|
|
explicit experimental_async(Stub* stub): stub_(stub) { } |
|
|
|
|
Stub* stub() { return stub_; } |
|
|
|
|
Stub* stub_; |
|
|
|
|
}; |
|
|
|
|
class experimental_async_interface* experimental_async() override { return &async_stub_; } |
|
|
|
|
|
|
|
|
|
private: |
|
|
|
|
std::shared_ptr< ::grpc::ChannelInterface> channel_; |
|
|
|
|
class experimental_async async_stub_{this}; |
|
|
|
|
::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>* AsyncMethodA1Raw(::grpc::ClientContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq) override; |
|
|
|
|
::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>* PrepareAsyncMethodA1Raw(::grpc::ClientContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq) override; |
|
|
|
|
::grpc::ClientWriter< ::grpc::testing::Request>* MethodA2Raw(::grpc::ClientContext* context, ::grpc::testing::Response* response) override; |
|
|
|
@ -488,6 +517,13 @@ class ServiceB final { |
|
|
|
|
return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::grpc::testing::Response>>(PrepareAsyncMethodB1Raw(context, request, cq)); |
|
|
|
|
} |
|
|
|
|
// MethodB1 trailing comment 1 |
|
|
|
|
class experimental_async_interface { |
|
|
|
|
public: |
|
|
|
|
// MethodB1 leading comment 1 |
|
|
|
|
virtual void MethodB1(::grpc::ClientContext* context, const ::grpc::testing::Request* request, ::grpc::testing::Response* response, std::function<void(::grpc::Status)>) = 0; |
|
|
|
|
// MethodB1 trailing comment 1 |
|
|
|
|
}; |
|
|
|
|
virtual class experimental_async_interface* experimental_async() { return nullptr; } |
|
|
|
|
private: |
|
|
|
|
virtual ::grpc::ClientAsyncResponseReaderInterface< ::grpc::testing::Response>* AsyncMethodB1Raw(::grpc::ClientContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq) = 0; |
|
|
|
|
virtual ::grpc::ClientAsyncResponseReaderInterface< ::grpc::testing::Response>* PrepareAsyncMethodB1Raw(::grpc::ClientContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq) = 0; |
|
|
|
@ -502,9 +538,21 @@ class ServiceB final { |
|
|
|
|
std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>> PrepareAsyncMethodB1(::grpc::ClientContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq) { |
|
|
|
|
return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>>(PrepareAsyncMethodB1Raw(context, request, cq)); |
|
|
|
|
} |
|
|
|
|
class experimental_async final : |
|
|
|
|
public StubInterface::experimental_async_interface { |
|
|
|
|
public: |
|
|
|
|
void MethodB1(::grpc::ClientContext* context, const ::grpc::testing::Request* request, ::grpc::testing::Response* response, std::function<void(::grpc::Status)>) override; |
|
|
|
|
private: |
|
|
|
|
friend class Stub; |
|
|
|
|
explicit experimental_async(Stub* stub): stub_(stub) { } |
|
|
|
|
Stub* stub() { return stub_; } |
|
|
|
|
Stub* stub_; |
|
|
|
|
}; |
|
|
|
|
class experimental_async_interface* experimental_async() override { return &async_stub_; } |
|
|
|
|
|
|
|
|
|
private: |
|
|
|
|
std::shared_ptr< ::grpc::ChannelInterface> channel_; |
|
|
|
|
class experimental_async async_stub_{this}; |
|
|
|
|
::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>* AsyncMethodB1Raw(::grpc::ClientContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq) override; |
|
|
|
|
::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>* PrepareAsyncMethodB1Raw(::grpc::ClientContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq) override; |
|
|
|
|
const ::grpc::internal::RpcMethod rpcmethod_MethodB1_; |
|
|
|
|