Remove ConcurrentChannel

Author: fantasy-peak

.github/workflows/rockylinux8-gcc13.yaml

@@ -46,7 +46,7 @@ jobs:
           xrepo install -y protobuf-cpp
           rm -rf example_project
           ls -lrt
-          export PATH=$HOME/.xmake/packages/p/protobuf-cpp/33.1/ef5a1f066f784334984fa37b1443301d/bin:$PATH
+          export PATH=/root/.xmake/packages/p/protobuf-cpp/33.2/b3738b6a93ec47949689248d7fcccfaa/bin:$PATH
           python3 proto2yaml.py example/example.proto \
               --namespace peak \
               --server_class_name GrpcServer \

example/include/grpc_server.hpp

@@ -78,16 +78,6 @@ using ExampleServerStreamingRPC = agrpc::ServerRPC<
     &fantasy::v1::Example::AsyncService::RequestServerStreaming>;
 using ExampleClientStreamingRPC = agrpc::ServerRPC<
     &fantasy::v1::Example::AsyncService::RequestClientStreaming>;
-#ifdef AGRPC_BOOST_ASIO
-template <typename T>
-using ConcurrentChannel =
-    asio::experimental::concurrent_channel<void(boost::system::error_code, T)>;
-#else
-template <typename T>
-using ConcurrentChannel =
-    asio::experimental::concurrent_channel<void(asio::error_code, T)>;
-#endif
-
 /*************************************************** */
 #if USE_GRPC_NOTIFY_WHEN_DONE
 struct GrpcServerServerRPCNotifyWhenDoneTraits : agrpc::DefaultServerRPCTraits {

example/src/server.cpp

@@ -125,9 +125,10 @@ struct TestServer {
         waiter.initiate(agrpc::read, rpc, request);
 
         using DATA = std::shared_ptr<Message<std::string>>;
-        auto chan =
-            std::make_shared<peak::ConcurrentChannel<DATA>>(rpc.get_executor(),
-                                                            m_channel_size);
+        using ConcurrentChannel = boost::asio::experimental::concurrent_channel<
+            void(boost::system::error_code, DATA)>;
+        auto chan = std::make_shared<ConcurrentChannel>(rpc.get_executor(),
+                                                        m_channel_size);
 
         auto stop_chan = std::make_shared<StopChannel>(rpc.get_executor(), 1);
 

example_project/include/grpc_server.hpp

@@ -78,16 +78,6 @@ using ExampleServerStreamingRPC = agrpc::ServerRPC<
     &fantasy::v1::Example::AsyncService::RequestServerStreaming>;
 using ExampleClientStreamingRPC = agrpc::ServerRPC<
     &fantasy::v1::Example::AsyncService::RequestClientStreaming>;
-#ifdef AGRPC_BOOST_ASIO
-template <typename T>
-using ConcurrentChannel =
-    asio::experimental::concurrent_channel<void(boost::system::error_code, T)>;
-#else
-template <typename T>
-using ConcurrentChannel =
-    asio::experimental::concurrent_channel<void(asio::error_code, T)>;
-#endif
-
 /*************************************************** */
 #if USE_GRPC_NOTIFY_WHEN_DONE
 struct GrpcServerServerRPCNotifyWhenDoneTraits : agrpc::DefaultServerRPCTraits {

template/grpc_server.hpp.j2

@@ -76,14 +76,6 @@ using {{service_name}}{{interface.name}}RPC = agrpc::ServerRPC<&{{grpc.package}}
 {% endfor -%}
 {% endfor -%}
 
-#ifdef AGRPC_BOOST_ASIO
-template <typename T>
-using ConcurrentChannel = asio::experimental::concurrent_channel<void(boost::system::error_code, T)>;
-#else
-template <typename T>
-using ConcurrentChannel = asio::experimental::concurrent_channel<void(asio::error_code, T)>;
-#endif
-
 /*************************************************** */
 #if USE_GRPC_NOTIFY_WHEN_DONE
 struct {{grpc.server_class_name}}ServerRPCNotifyWhenDoneTraits : agrpc::DefaultServerRPCTraits {