[−][src]Trait gio::InputStreamExt

pub trait InputStreamExt: 'static {
    fn clear_pending(&self);

    fn close<'a, P: IsA<Cancellable> + 'a, Q: Into<Option<&'a P>>>(
        &self, 
        cancellable: Q
    ) -> Result<(), Error>;

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

    fn has_pending(&self) -> bool;

    fn is_closed(&self) -> bool;

    fn read_bytes<'a, P: IsA<Cancellable> + 'a, Q: Into<Option<&'a P>>>(
        &self, 
        count: usize, 
        cancellable: Q
    ) -> Result<Bytes, Error>;

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

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

    fn skip<'a, P: IsA<Cancellable> + 'a, Q: Into<Option<&'a P>>>(
        &self, 
        count: usize, 
        cancellable: Q
    ) -> Result<isize, Error>;

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

Required methods

fn clear_pending(&self)

fn close<'a, P: IsA<Cancellable> + 'a, Q: Into<Option<&'a P>>>(
    &self,
    cancellable: Q
) -> Result<(), Error>

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

fn has_pending(&self) -> bool

fn is_closed(&self) -> bool

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

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

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

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

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

Loading content...

Implementors

impl<O: IsA<InputStream>> InputStreamExt for O[src]

Loading content...