Trait gio::prelude::InputStreamExt

pub trait InputStreamExt: 'static {
    // Required methods
    fn clear_pending(&self);
    fn close(
        &self,
        cancellable: Option<&impl IsA<Cancellable>>
    ) -> Result<(), Error>;
    fn close_async<P: FnOnce(Result<(), Error>) + 'static>(
        &self,
        io_priority: Priority,
        cancellable: Option<&impl IsA<Cancellable>>,
        callback: P
    );
    fn close_future(
        &self,
        io_priority: Priority
    ) -> Pin<Box_<dyn Future<Output = Result<(), Error>> + 'static>>;
    fn has_pending(&self) -> bool;
    fn is_closed(&self) -> bool;
    fn read_bytes(
        &self,
        count: usize,
        cancellable: Option<&impl IsA<Cancellable>>
    ) -> Result<Bytes, Error>;
    fn read_bytes_async<P: FnOnce(Result<Bytes, Error>) + 'static>(
        &self,
        count: usize,
        io_priority: Priority,
        cancellable: Option<&impl IsA<Cancellable>>,
        callback: P
    );
    fn read_bytes_future(
        &self,
        count: usize,
        io_priority: Priority
    ) -> Pin<Box_<dyn Future<Output = Result<Bytes, Error>> + 'static>>;
    fn set_pending(&self) -> Result<(), Error>;
    fn skip(
        &self,
        count: usize,
        cancellable: Option<&impl IsA<Cancellable>>
    ) -> Result<isize, Error>;
    fn skip_async<P: FnOnce(Result<isize, Error>) + 'static>(
        &self,
        count: usize,
        io_priority: Priority,
        cancellable: Option<&impl IsA<Cancellable>>,
        callback: P
    );
    fn skip_future(
        &self,
        count: usize,
        io_priority: Priority
    ) -> Pin<Box_<dyn Future<Output = Result<isize, Error>> + 'static>>;
}

Required Methods

fn clear_pending(&self)

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

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

fn close_future( &self, io_priority: Priority ) -> Pin<Box_<dyn Future<Output = Result<(), Error>> + 'static>>

fn has_pending(&self) -> bool

fn is_closed(&self) -> bool

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

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

fn read_bytes_future( &self, count: usize, io_priority: Priority ) -> Pin<Box_<dyn Future<Output = Result<Bytes, Error>> + 'static>>

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

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

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

fn skip_future( &self, count: usize, io_priority: Priority ) -> Pin<Box_<dyn Future<Output = Result<isize, Error>> + 'static>>

Implementors

impl<O: IsA<InputStream>> InputStreamExt for O