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

Implementors