MCPcopy Create free account
hub / github.com/AlexInLog/ReactivePlusPlus / Service

Method Service

src/examples/rppgrpc/communication/server.cpp:13–16  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

11{
12public:
13 Service()
14 {
15 client_side_requests.get_observable().subscribe([](const Request& s) { std::cout << "[ClientSideRequest]: " << s.ShortDebugString() << std::endl; });
16 }
17
18 grpc::ServerBidiReactor<::Request, ::Response>* Bidirectional(::grpc::CallbackServerContext* /*context*/) override
19 {

Callers

nothing calls this directly

Calls 2

subscribeMethod · 0.45
get_observableMethod · 0.45

Tested by

no test coverage detected