| /external/pigweed/pw_rpc/ |
| D | base_server_writer_test.cc | 80 TEST(ServerWriter, DefaultConstruct_Closed) { in TEST() argument
86 TEST(ServerWriter, Construct_RegistersWithServer) { in TEST() argument
97 TEST(ServerWriter, Destruct_RemovesFromServer) { in TEST() argument
105 TEST(ServerWriter, Finish_RemovesFromServer) { in TEST() argument
115 TEST(ServerWriter, Finish_SendsCancellationPacket) { in TEST() argument
130 TEST(ServerWriter, Finish_ReturnsStatusFromChannelSend) { in TEST() argument
138 TEST(ServerWriter, Close) { in TEST() argument
148 TEST(ServerWriter, Close_ReleasesBuffer) { in TEST() argument
161 TEST(ServerWriter, Open_SendsPacketWithPayload) { in TEST() argument
179 TEST(ServerWriter, Closed_IgnoresFinish) { in TEST() argument
|
| /external/pigweed/pw_rpc/nanopb/public/pw_rpc/internal/ |
| D | nanopb_method.h | 35 class ServerWriter : public internal::BaseServerWriter {
39 constexpr ServerWriter() = default;
41 ServerWriter(ServerWriter&&) = default;
42 ServerWriter& operator=(ServerWriter&&) = default;
85 ServerContext&, const RequestType&, ServerWriter<ResponseType>&)> {
98 ServerContext&, const RequestType&, ServerWriter<ResponseType>&)>
100 ServerContext&, const RequestType&, ServerWriter<ResponseType>&)> {
170 static_cast<ServerWriter<Response<method>>&>(writer));
304 Status ServerWriter<T>::Write(const T& response) {
|
| /external/pigweed/pw_rpc/nanopb/ |
| D | nanopb_method_test.cc | 44 void ServerStreaming(ServerContext&, const FakePb&, ServerWriter<FakePb>&) {} in ServerStreaming()
48 ServerWriter<FakePb>&) {} in StaticServerStreaming()
56 ServerWriter<FakePb>&) { in ServerStreamingBadReturn()
61 ServerWriter<FakePb>&) {} in StaticServerStreamingMissingArg()
129 ServerWriter<pw_rpc_test_TestResponse> last_writer;
145 ServerWriter<pw_rpc_test_TestResponse>& writer) { in StartStream()
277 ServerWriter<pw_rpc_test_TestResponse> new_writer = std::move(last_writer); in TEST()
|
| D | docs.rst | 101 ``ServerWriter``, used to stream back responses.
107 pw::rpc::ServerWriter<ListUsersResponse>& writer);
109 The ``ServerWriter`` object is movable, and remains active until it is manually
112 .. cpp:function:: Status ServerWriter::Write(const T& response)
117 .. cpp:function:: void ServerWriter::Finish(Status status = OkStatus())
121 Once a ``ServerWriter`` has been closed, all future ``Write`` calls will fail.
125 Make sure to use ``std::move`` when passing the ``ServerWriter`` around to
|
| D | nanopb_method_union_test.cc | 59 ServerWriter<pw_rpc_test_TestResponse> last_writer;
85 ServerWriter<pw_rpc_test_TestResponse>& writer) { in StartStream()
|
| D | method_lookup_test.cc | 31 ServerWriter<pw_rpc_test_TestStreamResponse>&) { in TestStreamRpc()
|
| /external/pigweed/pw_metric/ |
| D | metric_service_nanopb.cc | 30 MetricWriter(rpc::ServerWriter<pw_metric_MetricResponse>& response_writer) in MetricWriter()
81 rpc::ServerWriter<pw_metric_MetricResponse>& response_writer_;
132 ServerWriter<pw_metric_MetricResponse>& response) { in Get()
|
| /external/pigweed/pw_rpc/nanopb/public/pw_rpc/ |
| D | nanopb_test_method_context.h | 217 static_cast<ServerWriter<Response>&>(server_writer)); in call()
222 ServerWriter<Response> writer() { in writer()
225 return std::move(static_cast<ServerWriter<Response>&>(server_writer)); in writer()
|
| /external/pigweed/pw_trace_tokenized/public/pw_trace_tokenized/ |
| D | trace_rpc_service_nanopb.h | 32 ServerWriter<pw_trace_TraceDataMessage>& writer);
|
| /external/pigweed/pw_metric/public/pw_metric/ |
| D | metric_service_nanopb.h | 42 ServerWriter<pw_metric_MetricResponse>& response);
|
| /external/llvm-project/clang-tools-extra/clangd/index/remote/server/ |
| D | Server.cpp | 101 grpc::ServerWriter<LookupReply> *Reply) override { in Lookup()
139 grpc::ServerWriter<FuzzyFindReply> *Reply) override { in FuzzyFind()
177 grpc::ServerWriter<RefsReply> *Reply) override { in Refs()
215 grpc::ServerWriter<RelationsReply> *Reply) override { in Relations()
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | method_handler_impl.h | 147 ServerWriter<ResponseType>*)> in ServerStreamingHandler()
158 ServerWriter<ResponseType> writer(param.call, param.server_context); in RunHandler()
182 ServerWriter<ResponseType>*)>
|
| D | server_context.h | 54 class ServerWriter; variable
257 friend class ::grpc::ServerWriter;
|
| D | completion_queue.h | 55 class ServerWriter; variable
258 friend class ::grpc::ServerWriter;
|
| /external/grpc-grpc/examples/cpp/route_guide/ |
| D | route_guide_server.cc | 39 using grpc::ServerWriter;
100 ServerWriter<Feature>* writer) override { in ListFeatures()
|
| /external/grpc-grpc/test/cpp/util/ |
| D | metrics_server.h | 74 ServerWriter<GaugeResponse>* writer) override;
|
| D | metrics_server.cc | 55 ServerWriter<GaugeResponse>* writer) { in GetAllGauges()
|
| /external/pigweed/pw_trace_tokenized/ |
| D | trace_rpc_service_nanopb.cc | 43 ServerWriter<pw_trace_TraceDataMessage>& writer) { in GetTraceData()
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | test_service_impl.h | 62 ServerWriter<EchoResponse>* writer) override;
|
| D | server_crash_test.cc | 69 ServerWriter<EchoResponse>* writer) override { in ResponseStream()
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
| D | method_handler.h | 193 const RequestType*, ServerWriter<ResponseType>*)> in ServerStreamingHandler()
201 ServerWriter<ResponseType> writer( in RunHandler()
249 const RequestType*, ServerWriter<ResponseType>*)>
|
| D | completion_queue.h | 58 class ServerWriter; variable
271 friend class ::grpc::ServerWriter;
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
| D | method_handler.h | 193 const RequestType*, ServerWriter<ResponseType>*)> in ServerStreamingHandler()
201 ServerWriter<ResponseType> writer( in RunHandler()
249 const RequestType*, ServerWriter<ResponseType>*)>
|
| D | completion_queue.h | 58 class ServerWriter; variable
271 friend class ::grpc::ServerWriter;
|
| /external/flatbuffers/grpc/samples/greeter/ |
| D | server.cpp | 44 grpc::ServerWriter<flatbuffers::grpc::Message<HelloReply>> *writer) in SayManyHellos()
|