update rpccode

examples/rpc_example/test_client/test_client.cpp

@@ -1,23 +1,10 @@
 #include "test_client.hpp"
 
-call_Test_HowAreYou::call_Test_HowAreYou(chr::grpc_async_client_t *client) : test_rsp_sync_call_t(client)
+template <> 
+int call_Service_API<rpcpb::Test, rpcpb::TestReq, rpcpb::TestRsp>::call_impl()
 {
-}
-
-call_Test_HowAreYou::call_Test_HowAreYou(call_Test_HowAreYou &other) : test_rsp_sync_call_t(other)
-{
-	m_req = other.m_req;
-}
-
-int call_Test_HowAreYou::call_impl()
-{
-	m_stub = rpcpb::Test::NewStub(m_client_ptr->m_channel);
-	m_rsp_reader = m_stub->AsyncHowAreYou(&m_context, m_req, &m_client_ptr->m_completion_que);
-	m_rsp_reader->Finish(&m_result, &m_status, (void*)this);
-	return 0;
-}
-
-chr::client_call_it * call_Test_HowAreYou::clone_me()
-{
-	return new call_Test_HowAreYou(*this);
+    m_stub = rpcpb::Test::NewStub(m_client_ptr->m_channel);
+    m_rsp_reader = m_stub->AsyncHowAreYou(&m_context, m_req, &m_client_ptr->m_completion_que);
+    m_rsp_reader->Finish(&m_result, &m_status, (void*)this);
+    return 0;
 }

examples/rpc_example/test_client/test_client.hpp

@@ -6,22 +6,6 @@
 #include "test.grpc.pb.h"
 #include "grpc_sync_client_for_chroutine.hpp"
 
-typedef chr::client_sync_call_t<rpcpb::TestRsp> test_rsp_sync_call_t;
-
-class call_Test_HowAreYou final : public test_rsp_sync_call_t
-{
-public:
-	call_Test_HowAreYou(chr::grpc_async_client_t *client);
-	call_Test_HowAreYou(call_Test_HowAreYou &other);
-
-private:
-	chr::client_call_it * clone_me();
-	int call_impl();
-
-public:
-	std::unique_ptr<rpcpb::Test::Stub> m_stub;
-	rpcpb::TestReq m_req;
-	std::unique_ptr<::grpc::ClientAsyncResponseReader<rpcpb::TestRsp> > m_rsp_reader;
-};
+template <> int call_Service_API<rpcpb::Test, rpcpb::TestReq, rpcpb::TestRsp>::call_impl(); // for API: Test::HowAreYou
 
 #endif

examples/rpc_example/test_client/test_client_main.cpp

@@ -18,7 +18,7 @@ int main(int argc, char **argv)
         SPDLOG(INFO, "grpc_async_client_t {:p} created, is it ready? {}", (void*)client, client->ready());
 
         int i = 0;
-        call_Test_HowAreYou caller(client);
+        call_Service_API<rpcpb::Test, rpcpb::TestReq, rpcpb::TestRsp> howareyou_caller(client);
         rpcpb::TestRsp rsp;
 
         while (client) {            
@@ -31,7 +31,7 @@ int main(int argc, char **argv)
             // }
 
             SPDLOG(INFO, "try to call call_Test_HowAreYou the {}th time, is it ready? {}", i, client->ready());
-            ::grpc::StatusCode code = caller.call_sync(rsp);
+            ::grpc::StatusCode code = howareyou_caller.call_sync(rsp);
             SPDLOG(INFO, "call_Test_HowAreYou code={} , rsp:{}. clinet ready? {} ", code, rsp.rsp(), client->ready());
 
             // how we destroy a client