pub trait AsyncSessionStream {
    fn x_with<'life0, 'life1, 'async_trait, R>(
        &'life0 self,
        op: impl 'async_trait + FnMut() -> Result<R, Ssh2Error> + Send,
        sess: &'life1 Session,
        expected_block_directions: BlockDirections,
        sleep_dur: Option<Duration>
    ) -> Pin<Box<dyn Future<Output = Result<R, Error>> + Send + 'async_trait>>
    where
        R: 'async_trait,
        Self: 'async_trait,
        'life0: 'async_trait,
        'life1: 'async_trait
; fn poll_x_with<R>(
        &self,
        cx: &mut Context<'_>,
        op: impl FnMut() -> Result<R, IoError> + Send,
        sess: &Session,
        expected_block_directions: BlockDirections,
        sleep_dur: Option<Duration>
    ) -> Poll<Result<R, IoError>>; fn rw_with<'life0, 'life1, 'async_trait, R>(
        &'life0 self,
        op: impl 'async_trait + FnMut() -> Result<R, Ssh2Error> + Send,
        sess: &'life1 Session
    ) -> Pin<Box<dyn Future<Output = Result<R, Error>> + Send + 'async_trait>>
    where
        R: 'async_trait,
        Self: Sync + 'async_trait,
        'life0: 'async_trait,
        'life1: 'async_trait
, { ... } fn none_with<'life0, 'life1, 'async_trait, R>(
        &'life0 self,
        op: impl 'async_trait + FnMut() -> Result<R, Ssh2Error> + Send,
        sess: &'life1 Session
    ) -> Pin<Box<dyn Future<Output = Result<R, Error>> + Send + 'async_trait>>
    where
        R: 'async_trait,
        Self: Sync + 'async_trait,
        'life0: 'async_trait,
        'life1: 'async_trait
, { ... } fn read_with<'life0, 'life1, 'async_trait, R>(
        &'life0 self,
        op: impl 'async_trait + FnMut() -> Result<R, Ssh2Error> + Send,
        sess: &'life1 Session
    ) -> Pin<Box<dyn Future<Output = Result<R, Error>> + Send + 'async_trait>>
    where
        R: 'async_trait,
        Self: Sync + 'async_trait,
        'life0: 'async_trait,
        'life1: 'async_trait
, { ... } fn write_with<'life0, 'life1, 'async_trait, R>(
        &'life0 self,
        op: impl 'async_trait + FnMut() -> Result<R, Ssh2Error> + Send,
        sess: &'life1 Session
    ) -> Pin<Box<dyn Future<Output = Result<R, Error>> + Send + 'async_trait>>
    where
        R: 'async_trait,
        Self: Sync + 'async_trait,
        'life0: 'async_trait,
        'life1: 'async_trait
, { ... } fn poll_read_with<R>(
        &self,
        cx: &mut Context<'_>,
        op: impl FnMut() -> Result<R, IoError> + Send,
        sess: &Session
    ) -> Poll<Result<R, IoError>> { ... } fn poll_write_with<R>(
        &self,
        cx: &mut Context<'_>,
        op: impl FnMut() -> Result<R, IoError> + Send,
        sess: &Session
    ) -> Poll<Result<R, IoError>> { ... } }

Required Methods§

source

fn x_with<'life0, 'life1, 'async_trait, R>(
    &'life0 self,
    op: impl 'async_trait + FnMut() -> Result<R, Ssh2Error> + Send,
    sess: &'life1 Session,
    expected_block_directions: BlockDirections,
    sleep_dur: Option<Duration>
) -> Pin<Box<dyn Future<Output = Result<R, Error>> + Send + 'async_trait>>where
    R: 'async_trait,
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

source

fn poll_x_with<R>(
    &self,
    cx: &mut Context<'_>,
    op: impl FnMut() -> Result<R, IoError> + Send,
    sess: &Session,
    expected_block_directions: BlockDirections,
    sleep_dur: Option<Duration>
) -> Poll<Result<R, IoError>>

Provided Methods§

source

fn rw_with<'life0, 'life1, 'async_trait, R>(
    &'life0 self,
    op: impl 'async_trait + FnMut() -> Result<R, Ssh2Error> + Send,
    sess: &'life1 Session
) -> Pin<Box<dyn Future<Output = Result<R, Error>> + Send + 'async_trait>>where
    R: 'async_trait,
    Self: Sync + 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

source

fn none_with<'life0, 'life1, 'async_trait, R>(
    &'life0 self,
    op: impl 'async_trait + FnMut() -> Result<R, Ssh2Error> + Send,
    sess: &'life1 Session
) -> Pin<Box<dyn Future<Output = Result<R, Error>> + Send + 'async_trait>>where
    R: 'async_trait,
    Self: Sync + 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

source

fn read_with<'life0, 'life1, 'async_trait, R>(
    &'life0 self,
    op: impl 'async_trait + FnMut() -> Result<R, Ssh2Error> + Send,
    sess: &'life1 Session
) -> Pin<Box<dyn Future<Output = Result<R, Error>> + Send + 'async_trait>>where
    R: 'async_trait,
    Self: Sync + 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

source

fn write_with<'life0, 'life1, 'async_trait, R>(
    &'life0 self,
    op: impl 'async_trait + FnMut() -> Result<R, Ssh2Error> + Send,
    sess: &'life1 Session
) -> Pin<Box<dyn Future<Output = Result<R, Error>> + Send + 'async_trait>>where
    R: 'async_trait,
    Self: Sync + 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

source

fn poll_read_with<R>(
    &self,
    cx: &mut Context<'_>,
    op: impl FnMut() -> Result<R, IoError> + Send,
    sess: &Session
) -> Poll<Result<R, IoError>>

source

fn poll_write_with<R>(
    &self,
    cx: &mut Context<'_>,
    op: impl FnMut() -> Result<R, IoError> + Send,
    sess: &Session
) -> Poll<Result<R, IoError>>

Implementations on Foreign Types§

source§

impl<S> AsyncSessionStream for Async<S>where
    S: Send + Sync,

source§

fn x_with<'life0, 'life1, 'async_trait, R>(
    &'life0 self,
    op: impl 'async_trait + FnMut() -> Result<R, Ssh2Error> + Send,
    sess: &'life1 Session,
    expected_block_directions: BlockDirections,
    sleep_dur: Option<Duration>
) -> Pin<Box<dyn Future<Output = Result<R, Error>> + Send + 'async_trait>>where
    R: 'async_trait,
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

source§

fn poll_x_with<R>(
    &self,
    cx: &mut Context<'_>,
    op: impl FnMut() -> Result<R, IoError> + Send,
    sess: &Session,
    expected_block_directions: BlockDirections,
    sleep_dur: Option<Duration>
) -> Poll<Result<R, IoError>>

Implementors§