Trait gio::prelude::InputStreamExt
source · [−]pub trait InputStreamExt: 'static {
Show 13 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
source
fn clear_pending(&self)
sourcefn close_async<P: FnOnce(Result<(), Error>) + 'static>(
fn close_async<P: FnOnce(Result<(), Error>) + 'static>(
&self,
io_priority: Priority,
cancellable: Option<&impl IsA<Cancellable>>,
callback: P
)
sourcefn close_future(
fn close_future(
&self,
io_priority: Priority
) -> Pin<Box_<dyn Future<Output = Result<(), Error>> + 'static>>
source
fn has_pending(&self) -> bool
sourcefn read_bytes(
fn read_bytes(
&self,
count: usize,
cancellable: Option<&impl IsA<Cancellable>>
) -> Result<Bytes, Error>
sourcefn read_bytes_async<P: FnOnce(Result<Bytes, Error>) + 'static>(
fn read_bytes_async<P: FnOnce(Result<Bytes, Error>) + 'static>(
&self,
count: usize,
io_priority: Priority,
cancellable: Option<&impl IsA<Cancellable>>,
callback: P
)
sourcefn read_bytes_future(
fn read_bytes_future(
&self,
count: usize,
io_priority: Priority
) -> Pin<Box_<dyn Future<Output = Result<Bytes, Error>> + 'static>>
source
fn set_pending(&self) -> Result<(), Error>
sourcefn skip(