Struct StreamAdaptor

pub struct StreamAdaptor<S> { /* private fields */ }

An adaptor that implements a Stream for a type that implements X11rbStream.

Implementations

impl<S: AsFd> StreamAdaptor<S>

pub fn new(stream: S) -> Result<Self>

Create a new StreamAdaptor from a stream.

Trait Implementations

impl<S: Debug> Debug for StreamAdaptor<S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<S: X11rbStream> Stream for StreamAdaptor<S>

fn poll(&self, mode: PollMode) -> Result<()>

Waits for level-triggered read and/or write events on the stream.

fn read( &self, buf: &mut [u8], fd_storage: &mut Vec<RawFdContainer>, ) -> Result<usize>

Read some bytes and FDs from this reader without blocking, returning how many bytes were read.

fn write(&self, buf: &[u8], fds: &mut Vec<RawFdContainer>) -> Result<usize>

Write a buffer and some FDs into this writer without blocking, returning how many bytes were written.

fn write_vectored( &self, bufs: &[IoSlice<'_>], fds: &mut Vec<RawFdContainer>, ) -> Result<usize>

Like write, except that it writes from a slice of buffers. Like write, this method must never block.

impl<'a, S: 'a + X11rbStream + Sync> StreamBase<'a> for StreamAdaptor<S>

type Readable = Readable<'a, S>

The future returned by readable.

type Writable = Writable<'a, S>

The future returned by writable.

fn readable(&'a self) -> Self::Readable

Wait until the stream is readable.

fn writable(&'a self) -> Self::Writable

Wait until the stream is writable.