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

Implementors