State for the stream-writing thread. More...
#include <stream_channel.h>
Public Member Functions | |
StreamChannelWriteState (const StreamChannelWriteState &)=delete | |
StreamChannelWriteState & | operator= (const StreamChannelWriteState &)=delete |
StreamChannelWriteState (StreamChannelWriteState &&)=delete | |
StreamChannelWriteState & | operator= (StreamChannelWriteState &&)=delete |
Status | SendData (multibuf::MultiBuf &&buf) |
void | WriteLoop (stream::Writer &writer) |
State for the stream-writing thread.
Status pw::channel::internal::StreamChannelWriteState::SendData | ( | multibuf::MultiBuf && | buf | ) |
Queues buf
to be sent into writer
via the WriteLoop
.
Returns a status indicating whether the WriteLoop
has encountered errors writing into writer
.
void pw::channel::internal::StreamChannelWriteState::WriteLoop | ( | stream::Writer & | writer | ) |
A loop which writes the data sent via SendData
into writer
.
This is blocking and is intended to be run on an independent thread.