Trait InputStreamExt

Source
pub trait InputStreamExt: 'static {
    // Required methods
    fn clear_pending(&self);
    fn close<P: IsA<Cancellable>>(
        &self,
        cancellable: Option<&P>,
    ) -> Result<(), Error>;
    fn close_async<P: IsA<Cancellable>, Q: FnOnce(Result<(), Error>) + Send + 'static>(
        &self,
        io_priority: Priority,
        cancellable: Option<&P>,
        callback: Q,
    );
    fn has_pending(&self) -> bool;
    fn is_closed(&self) -> bool;
    fn read_bytes<P: IsA<Cancellable>>(
        &self,
        count: usize,
        cancellable: Option<&P>,
    ) -> Result<Bytes, Error>;
    fn read_bytes_async<P: IsA<Cancellable>, Q: FnOnce(Result<Bytes, Error>) + Send + 'static>(
        &self,
        count: usize,
        io_priority: Priority,
        cancellable: Option<&P>,
        callback: Q,
    );
    fn set_pending(&self) -> Result<(), Error>;
    fn skip<P: IsA<Cancellable>>(
        &self,
        count: usize,
        cancellable: Option<&P>,
    ) -> Result<isize, Error>;
    fn skip_async<P: IsA<Cancellable>, Q: FnOnce(Result<isize, Error>) + Send + 'static>(
        &self,
        count: usize,
        io_priority: Priority,
        cancellable: Option<&P>,
        callback: Q,
    );
}

Required Methods§

Source

fn clear_pending(&self)

Source

fn close<P: IsA<Cancellable>>( &self, cancellable: Option<&P>, ) -> Result<(), Error>

Source

fn close_async<P: IsA<Cancellable>, Q: FnOnce(Result<(), Error>) + Send + 'static>( &self, io_priority: Priority, cancellable: Option<&P>, callback: Q, )

Source

fn has_pending(&self) -> bool

Source

fn is_closed(&self) -> bool

Source

fn read_bytes<P: IsA<Cancellable>>( &self, count: usize, cancellable: Option<&P>, ) -> Result<Bytes, Error>

Source

fn read_bytes_async<P: IsA<Cancellable>, Q: FnOnce(Result<Bytes, Error>) + Send + 'static>( &self, count: usize, io_priority: Priority, cancellable: Option<&P>, callback: Q, )

Source

fn set_pending(&self) -> Result<(), Error>

Source

fn skip<P: IsA<Cancellable>>( &self, count: usize, cancellable: Option<&P>, ) -> Result<isize, Error>

Source

fn skip_async<P: IsA<Cancellable>, Q: FnOnce(Result<isize, Error>) + Send + 'static>( &self, count: usize, io_priority: Priority, cancellable: Option<&P>, callback: Q, )

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§