Searched refs:BaseServerWriter (Results 1 – 12 of 12) sorted by relevance
38 class BaseServerWriter : public IntrusiveList<BaseServerWriter>::Item {40 BaseServerWriter(ServerCall& call);42 BaseServerWriter(const BaseServerWriter&) = delete;44 BaseServerWriter(BaseServerWriter&& other) : state_(kClosed) { in BaseServerWriter() function48 ~BaseServerWriter() { Finish(); } in ~BaseServerWriter()50 BaseServerWriter& operator=(const BaseServerWriter&) = delete;52 BaseServerWriter& operator=(BaseServerWriter&& other);65 constexpr BaseServerWriter() : state_{kClosed} {} in BaseServerWriter() function
24 void RegisterWriter(BaseServerWriter& writer) { in RegisterWriter()28 void RemoveWriter(const BaseServerWriter& writer) { in RemoveWriter()
24 BaseServerWriter::BaseServerWriter(ServerCall& call) in BaseServerWriter() function in pw::rpc::internal::BaseServerWriter29 BaseServerWriter& BaseServerWriter::operator=(BaseServerWriter&& other) { in operator =()47 uint32_t BaseServerWriter::method_id() const { return call_.method().id(); } in method_id()49 Status BaseServerWriter::Finish(Status status) { in Finish()71 std::span<std::byte> BaseServerWriter::AcquirePayloadBuffer() { in AcquirePayloadBuffer()82 Status BaseServerWriter::ReleasePayloadBuffer( in ReleasePayloadBuffer()88 Status BaseServerWriter::ReleasePayloadBuffer() { in ReleasePayloadBuffer()94 void BaseServerWriter::Close() { in Close()103 Packet BaseServerWriter::ResponsePacket( in ResponsePacket()
42 TEST(BaseServerWriter, ConstructWithContext_StartsOpen) { in TEST() argument45 BaseServerWriter writer(context.get()); in TEST()50 TEST(BaseServerWriter, Move_ClosesOriginal) { in TEST() argument53 BaseServerWriter moved(context.get()); in TEST()54 BaseServerWriter writer(std::move(moved)); in TEST()62 class FakeServerWriter : public BaseServerWriter {64 FakeServerWriter(ServerCall& context) : BaseServerWriter(context) {} in FakeServerWriter()
240 internal::BaseServerWriter writer_;
24 class RawServerWriter : public internal::BaseServerWriter {68 [](ServerCall& call, ConstByteSpan request, BaseServerWriter& writer) { in ServerStreaming()86 BaseServerWriter&);
56 IntrusiveList<internal::BaseServerWriter>& writers() { return writers_; } in writers()71 IntrusiveList<internal::BaseServerWriter> writers_;
35 class ServerWriter : public internal::BaseServerWriter {166 [](ServerCall& call, const void* req, BaseServerWriter& writer) {213 BaseServerWriter& writer);
72 internal::BaseServerWriter server_writer(call); in CallServerStreaming()
213 internal::BaseServerWriter server_writer(ctx_.call); in call()224 internal::BaseServerWriter server_writer(ctx_.call); in writer()
219 BaseServerWriter server_writer(ctx_.call); in call()228 BaseServerWriter server_writer(ctx_.call); in writer()
45 internal::BaseServerWriter server_writer(call); in CallServerStreaming()