[go: up one dir, main page]

[][src]Trait gio::InputStreamExt

pub trait InputStreamExt: 'static {
    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

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
)

Loading content...

Implementors

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

Loading content...