Struct x11rb_async::rust_connection::StreamAdaptor

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

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

Implementations

impl<S: AsRaw> StreamAdaptor<S>

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

Create a new StreamAdaptor from a stream.

impl<S> StreamAdaptor<S>

pub fn get_ref(&self) -> &S

Get a reference to the inner stream.

pub fn get_mut(&mut self) -> &mut S

Get a mutable reference to the inner stream.

pub fn into_inner(self) -> Result<S>

Consume this adaptor and return the inner stream.

Trait Implementations

impl<S: AsRaw> AsRawFd for StreamAdaptor<S>

fn as_raw_fd(&self) -> RawFd

Extracts the raw file descriptor.

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.