Searched refs:response_writer_ (Results 1 – 4 of 4) sorted by relevance
35 response_writer_ = std::move(writer); in Get()41 if (!response_writer_.open()) { in Flush()48 ByteSpan payload = response_writer_.PayloadBuffer(); in Flush()51 PW_TRY(response_writer_.Write(dropped_log.value())); in Flush()58 ByteSpan payload = response_writer_.PayloadBuffer(); in Flush()65 Status status = response_writer_.Write(possible_logs.value().entries); in Flush()
44 void Finish() { response_writer_.Finish(); } in Finish()48 rpc::RawServerWriter response_writer_; variable
32 response_writer_(response_writer) {} in MetricWriter()73 response_writer_.Write(response_); in Flush()81 rpc::ServerWriter<pw_metric_MetricResponse>& response_writer_; member in pw::metric::__anon4653944a0111::MetricWriter
261 response_writer_(srv_ctx_.get()) { in ServerRpcContextUnaryImpl()262 request_method_(srv_ctx_.get(), &req_, &response_writer_, in ServerRpcContextUnaryImpl()270 response_writer_ = in Reset()275 request_method_(srv_ctx_.get(), &req_, &response_writer_, in Reset()291 response_writer_.Finish(response_, status, AsyncQpsServerTest::tag(this)); in invoker()302 grpc::ServerAsyncResponseWriter<ResponseType> response_writer_; member in grpc::testing::AsyncQpsServerTest::ServerRpcContextUnaryImpl