Struct async_transmit::With

pub struct With<T, F, I, U, E> { /* fields omitted */ }

Implementations

impl<T, F, I, U, E> With<T, F, I, U, E> where
    T: Transmit<Item = I, Error = E> + Send,
    I: Send,
    E: Send, 

pub fn into_inner(self) -> T

Consumes this combinator, returning the underlying transmit.

pub fn get_ref(&self) -> &T

Acquires a reference to the underlying transmit that this combinator is pulling from.

pub fn get_mut(&mut self) -> &mut T

Acquires a mutable reference to the underlying transmit that this combinator is pulling from.

Trait Implementations

impl<T: Debug, F: Debug, I: Debug, U: Debug, E: Debug> Debug for With<T, F, I, U, E>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T, F, I, U, E> Transmit for With<T, F, I, U, E> where
    T: Transmit<Item = I, Error = E> + Send,
    F: FnMut(U) -> I + Send,
    I: Send,
    U: Send,
    E: Send, 

type Item = U

type Error = E

fn transmit<'life0, 'async_trait>(
    &'life0 mut self,
    item: Self::Item
) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Attempts to transmit a value to the peer asynchronously.