struct PipeState {
buffer: VecDeque<u8>,
max_size: usize,
reader_count: usize,
writer_count: usize,
closed: bool,
}Expand description
Internal shared state of a pipe (data only, no wakers)
Fields§
§buffer: VecDeque<u8>Ring buffer for pipe data
max_size: usizeMaximum buffer size
reader_count: usizeNumber of active readers
writer_count: usizeNumber of active writers
closed: boolWhether the pipe has been closed