Struct SharedPipeData 

struct SharedPipeData {
    state: Mutex<PipeState>,
    read_waker: Waker,
    write_waker: Waker,
}

Shared pipe data including both state and wakers Wakers are kept outside the Mutex to avoid deadlock when calling wait()

Fields

state: Mutex<PipeState>

Main pipe state (protected by mutex)

read_waker: Waker

Waker for tasks waiting to read (outside mutex to avoid deadlock)

write_waker: Waker

Waker for tasks waiting to write (outside mutex to avoid deadlock)

Implementations

impl SharedPipeData

fn new(buffer_size: usize) -> Arc<Self>