pub struct Then<T, F> { /* private fields */ }Trait Implementations§
Source§impl<Bkend, T, S, F, Ct> BackendStreamingTask<Bkend> for Then<T, F>where
    Bkend: Clone + Sync + Send + 'static,
    F: Sync + Send + 'static + FnOnce(T::Output) -> S,
    T: BackendTask<Bkend, MetadataType = Ct>,
    S: BackendStreamingTask<Bkend, MetadataType = Ct>,
    Ct: PartialEq,
 
impl<Bkend, T, S, F, Ct> BackendStreamingTask<Bkend> for Then<T, F>where
    Bkend: Clone + Sync + Send + 'static,
    F: Sync + Send + 'static + FnOnce(T::Output) -> S,
    T: BackendTask<Bkend, MetadataType = Ct>,
    S: BackendStreamingTask<Bkend, MetadataType = Ct>,
    Ct: PartialEq,
type Output = <S as BackendStreamingTask<Bkend>>::Output
type MetadataType = Ct
fn into_stream( self, backend: &Bkend, ) -> impl Stream<Item = Self::Output> + Send + Unpin + 'static
Source§fn metadata() -> Vec<Self::MetadataType>
 
fn metadata() -> Vec<Self::MetadataType>
Metadata provides a way of grouping different tasks for use in
constraints, if you override the default implementation.
Source§impl<Bkend, T, T2, F, Ct> BackendTask<Bkend> for Then<T, F>where
    Bkend: Clone + Send + 'static,
    F: Sync + Send + 'static + FnOnce(T::Output) -> T2,
    T: BackendTask<Bkend, MetadataType = Ct>,
    T2: BackendTask<Bkend, MetadataType = Ct>,
    Ct: PartialEq,
 
impl<Bkend, T, T2, F, Ct> BackendTask<Bkend> for Then<T, F>where
    Bkend: Clone + Send + 'static,
    F: Sync + Send + 'static + FnOnce(T::Output) -> T2,
    T: BackendTask<Bkend, MetadataType = Ct>,
    T2: BackendTask<Bkend, MetadataType = Ct>,
    Ct: PartialEq,
type Output = <T2 as BackendTask<Bkend>>::Output
type MetadataType = Ct
fn into_future( self, backend: &Bkend, ) -> impl Future<Output = Self::Output> + Send + 'static
Source§fn metadata() -> Vec<Self::MetadataType>
 
fn metadata() -> Vec<Self::MetadataType>
Metadata provides a way of grouping different tasks for use in
constraints, if you override the default implementation.
Auto Trait Implementations§
impl<T, F> Freeze for Then<T, F>
impl<T, F> RefUnwindSafe for Then<T, F>where
    T: RefUnwindSafe,
    F: RefUnwindSafe,
impl<T, F> Send for Then<T, F>
impl<T, F> Sync for Then<T, F>
impl<T, F> Unpin for Then<T, F>
impl<T, F> UnwindSafe for Then<T, F>where
    T: UnwindSafe,
    F: UnwindSafe,
Blanket Implementations§
Source§impl<Bkend, T> BackendTaskExt<Bkend> for Twhere
    T: BackendTask<Bkend>,
 
impl<Bkend, T> BackendTaskExt<Bkend> for Twhere
    T: BackendTask<Bkend>,
Source§impl<T> BorrowMut<T> for Twhere
    T: ?Sized,
 
impl<T> BorrowMut<T> for Twhere
    T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
 
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more