[server-rpc-client-streaming-callback] */
| 59 | |
| 60 | /* [server-rpc-client-streaming-callback] */ |
| 61 | grpc::ServerReadReactor<example::v1::Request>* ClientStreaming(grpc::CallbackServerContext*, |
| 62 | example::v1::Response* response) override |
| 63 | { |
| 64 | auto ptr = agrpc::make_reactor<agrpc::ServerReadReactor<example::v1::Request>>(get_executor()); |
| 65 | auto& rpc = *ptr; |
| 66 | auto request = std::make_unique<example::v1::Request>(); |
| 67 | rpc.initiate_read(*request); |
| 68 | rpc.wait_for_read( |
| 69 | [response, ptr = std::move(ptr), request = std::move(request)](const error_code&, bool ok) |
| 70 | { |
| 71 | if (!ok) |
| 72 | { |
| 73 | return; |
| 74 | } |
| 75 | response->set_integer(request->integer()); |
| 76 | ptr->initiate_finish(grpc::Status::OK); |
| 77 | }); |
| 78 | return rpc.get(); |
| 79 | } |
| 80 | /* [server-rpc-client-streaming-callback] */ |
| 81 | |
| 82 | /* [server-rpc-server-streaming-callback] */ |
nothing calls this directly
no test coverage detected