| /aosp_15_r20/external/pigweed/pw_rpc/nanopb/ |
| H A D | client_reader_writer_test.cc | 54 NanopbClientWriter<pw_rpc_test_TestRequest, pw_rpc_test_TestStreamResponse> in TEST()
64 call.set_on_completed([](const pw_rpc_test_TestStreamResponse&, Status) {}); in TEST() argument
69 NanopbClientReader<pw_rpc_test_TestStreamResponse> call; in TEST()
78 call.set_on_next([](const pw_rpc_test_TestStreamResponse&) {}); in TEST() argument
84 pw_rpc_test_TestStreamResponse> in TEST()
95 call.set_on_next([](const pw_rpc_test_TestStreamResponse&) {}); in TEST() argument
101 NanopbClientWriter<pw_rpc_test_TestRequest, pw_rpc_test_TestStreamResponse> in TEST()
105 FailIfOnCompletedCalled<pw_rpc_test_TestStreamResponse>, in TEST()
116 call.set_on_completed([](const pw_rpc_test_TestStreamResponse&, Status) {}); in TEST() argument
122 NanopbClientReader<pw_rpc_test_TestStreamResponse> call = in TEST()
[all …]
|
| H A D | server_reader_writer_test.cc | 41 NanopbServerWriter<pw_rpc_test_TestStreamResponse>&) {} in TestServerStreamRpc() argument
45 pw_rpc_test_TestStreamResponse>&) {} in TestClientStreamRpc() argument
49 pw_rpc_test_TestStreamResponse>&) {} in TestBidirectionalStreamRpc() argument
82 NanopbServerWriter<pw_rpc_test_TestStreamResponse> call; in TEST()
94 NanopbServerReader<pw_rpc_test_TestRequest, pw_rpc_test_TestStreamResponse> in TEST()
108 pw_rpc_test_TestStreamResponse> in TEST()
139 NanopbServerWriter<pw_rpc_test_TestStreamResponse>::Open< in TEST()
156 NanopbServerWriter<pw_rpc_test_TestStreamResponse>::Open< in TEST()
170 NanopbServerWriter<pw_rpc_test_TestStreamResponse>::Open< in TEST()
190 pw_rpc_test_TestStreamResponse>:: in TEST()
[all …]
|
| H A D | client_call_test.cc | 77 static NanopbClientReader<pw_rpc_test_TestStreamResponse> TestServerStreamRpc( in TestServerStreamRpc()
81 Function<void(const pw_rpc_test_TestStreamResponse&)> on_response, in TestServerStreamRpc()
85 NanopbStreamResponseClientCall<pw_rpc_test_TestStreamResponse>::Start< in TestServerStreamRpc()
86 pw::rpc::NanopbClientReader<pw_rpc_test_TestStreamResponse>>( in TestServerStreamRpc()
288 [this](const pw_rpc_test_TestStreamResponse& response) { in TEST_F()
294 PW_ENCODE_PB(pw_rpc_test_TestStreamResponse, r1, .chunk = {}, .number = 11u); in TEST_F()
300 PW_ENCODE_PB(pw_rpc_test_TestStreamResponse, r2, .chunk = {}, .number = 22u); in TEST_F()
306 PW_ENCODE_PB(pw_rpc_test_TestStreamResponse, r3, .chunk = {}, .number = 33u); in TEST_F()
320 [this](const pw_rpc_test_TestStreamResponse& response) { in TEST_F()
326 PW_ENCODE_PB(pw_rpc_test_TestStreamResponse, r1, .chunk = {}, .number = 11u); in TEST_F()
[all …]
|
| H A D | codegen_test.cc | 48 ServerWriter<pw_rpc_test_TestStreamResponse>& writer) { in TestServerStreamRpc()
60 ServerReader<pw_rpc_test_TestRequest, pw_rpc_test_TestStreamResponse>& in TestClientStreamRpc()
67 pw_rpc_test_TestStreamResponse>& new_reader_writer) { in TestBidirectionalStreamRpc()
71 ServerReader<pw_rpc_test_TestRequest, pw_rpc_test_TestStreamResponse> reader;
72 ServerReaderWriter<pw_rpc_test_TestRequest, pw_rpc_test_TestStreamResponse>
207 NanopbClientReader<pw_rpc_test_TestStreamResponse> server_streaming_call; in TEST()
268 [&result](const pw_rpc_test_TestStreamResponse& response) { in TEST()
290 pw_rpc_test_TestStreamResponse, response, .chunk = {}, .number = 11u); in TEST()
354 [&result](const pw_rpc_test_TestStreamResponse& response) { in TEST()
376 pw_rpc_test_TestStreamResponse, response, .chunk = {}, .number = 11u); in TEST()
|
| H A D | callback_test.cc | 33 pw_rpc_test_TestStreamResponse>;
106 local_call.set_on_next([this](const pw_rpc_test_TestStreamResponse&) { in TEST_F() argument
147 [this](const pw_rpc_test_TestStreamResponse&) { in TEST_F() argument
179 [this](const pw_rpc_test_TestStreamResponse&) { in TEST_F() argument
206 [this](const pw_rpc_test_TestStreamResponse&) { in TEST_F() argument
237 [this](const pw_rpc_test_TestStreamResponse&) { in TEST_F() argument
|
| H A D | method_info_test.cc | 38 ServerWriter<pw_rpc_test_TestStreamResponse>&) {} in TestServerStreamRpc() argument
41 ServerReader<pw_rpc_test_TestRequest, pw_rpc_test_TestStreamResponse>&) {} in TestClientStreamRpc() argument
45 pw_rpc_test_TestStreamResponse>&) {} in TestBidirectionalStreamRpc() argument
|
| H A D | server_callback_test.cc | 60 NanopbServerWriter<pw_rpc_test_TestStreamResponse>&) {} in TestServerStreamRpc() argument
64 pw_rpc_test_TestStreamResponse>&) {} in TestClientStreamRpc() argument
68 pw_rpc_test_TestStreamResponse>&) {} in TestBidirectionalStreamRpc() argument
|
| H A D | method_lookup_test.cc | 37 ServerWriter<pw_rpc_test_TestStreamResponse>&) { in TestServerStreamRpc() argument
47 pw_rpc_test_TestStreamResponse>&) { in TestBidirectionalStreamRpc() argument
74 ServerReader<pw_rpc_test_TestRequest, pw_rpc_test_TestStreamResponse>&) { in TestClientStreamRpc() argument
|
| H A D | client_server_context_threaded_test.cc | 62 ServerWriter<pw_rpc_test_TestStreamResponse>&) {} in TestServerStreamRpc() argument
65 ServerReader<pw_rpc_test_TestRequest, pw_rpc_test_TestStreamResponse>&) {} in TestClientStreamRpc() argument
69 pw_rpc_test_TestStreamResponse>&) {} in TestBidirectionalStreamRpc() argument
|
| H A D | client_server_context_test.cc | 59 ServerWriter<pw_rpc_test_TestStreamResponse>&) {} in TestServerStreamRpc() argument
62 ServerReader<pw_rpc_test_TestRequest, pw_rpc_test_TestStreamResponse>&) {} in TestClientStreamRpc() argument
66 pw_rpc_test_TestStreamResponse>&) {} in TestBidirectionalStreamRpc() argument
|