19#include "pw_async2/dispatcher.h"
20#include "pw_async2/poll.h"
21#include "pw_channel/channel.h"
22#include "pw_multibuf/allocator.h"
23#include "pw_multibuf/allocator_async.h"
24#include "pw_multibuf/multibuf.h"
26namespace pw::channel {
32template <DataType kType>
45 :
public Implement<ReliableDatagramReaderWriter> {
48 : write_alloc_future_(write_allocator) {}
63 write_alloc_future_.SetDesiredSize(min_bytes);
64 return write_alloc_future_.Pend(cx);
74 std::optional<multibuf::MultiBuf> queue_;
81 :
public Implement<ReliableByteReaderWriter> {
84 : write_alloc_future_(write_allocator) {}
101 write_alloc_future_.SetDesiredSize(min_bytes);
102 return write_alloc_future_.Pend(cx);
Definition: channel.h:583
Definition: loopback_channel.h:81
Definition: loopback_channel.h:45
Definition: loopback_channel.h:33
Definition: allocator_async.h:91
Definition: allocator.h:55
Definition: multibuf_v1.h:246
constexpr Status OkStatus()
Definition: status.h:234