pub trait IOStreamExt: 'static {
fn clear_pending(&self);
fn close(
&self,
cancellable: Option<&impl IsA<Cancellable>>
) -> Result<(), Error>;
fn close_async<P: FnOnce(Result<(), Error>) + Send + '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 input_stream(&self) -> InputStream;
fn output_stream(&self) -> OutputStream;
fn has_pending(&self) -> bool;
fn is_closed(&self) -> bool;
fn set_pending(&self) -> Result<(), Error>;
fn connect_closed_notify<F: Fn(&Self) + 'static>(
&self,
f: F
) -> SignalHandlerId;
}
