Struct PipeRingBuffer 

pub(crate) struct PipeRingBuffer {
    buffer: RingBuffer,
    write_end: Option<Weak<Pipe>>,
}

管道环形缓冲区

Fields

buffer: RingBuffer

write_end: Option<Weak<Pipe>>

Implementations

impl PipeRingBuffer

pub fn new() -> Self

创建一个新的 PipeRingBuffer

pub fn read_byte(&mut self) -> Option<u8>

读取一个字节

pub fn write_byte(&mut self, byte: u8) -> Result<(), ()>

写入一个字节

pub fn available_space(&self) -> usize

可用空间

pub fn set_write_end(&mut self, write_end: &Arc<Pipe>)

设置写端

pub fn all_write_ends_dropped(&self) -> bool

检查是否所有写端都已被丢弃