struct PipeState {
buffer: VecDeque<u8>,
max_size: usize,
reader_count: usize,
writer_count: usize,
closed: bool,
}
Expand description
Internal shared state of a pipe
Fields§
§buffer: VecDeque<u8>
Ring buffer for pipe data
max_size: usize
Maximum buffer size
reader_count: usize
Number of active readers
writer_count: usize
Number of active writers
closed: bool
Whether the pipe has been closed