end-snippet
| 39 | |
| 40 | // end-snippet |
| 41 | void process_request(grpc::ByteBuffer& buffer) |
| 42 | { |
| 43 | // -- Deserialize the request message |
| 44 | example::v1::Request request; |
| 45 | const auto deserialize_status = |
| 46 | grpc::GenericDeserialize<grpc::ProtoBufferReader, example::v1::Request>(&buffer, &request); |
| 47 | |
| 48 | abort_if_not(deserialize_status.ok()); |
| 49 | |
| 50 | // -- Serialize the response message |
| 51 | example::v1::Response response; |
| 52 | response.set_integer(request.integer() * 2); |
| 53 | bool own_buffer; |
| 54 | grpc::GenericSerialize<grpc::ProtoBufferWriter, example::v1::Response>(response, &buffer, &own_buffer); |
| 55 | } |
| 56 | |
| 57 | void handle_generic_unary_request(agrpc::GenericServerRPC& rpc, const asio::yield_context& yield) |
| 58 | { |
no outgoing calls
no test coverage detected