pub trait DecoupleProcessStream<'a, T, L: Location<'a> + NoTick, B, Order> {
    // Required method
    fn decouple_process<P2>(
        self,
        other: &Process<'a, P2>,
    ) -> Stream<T, Process<'a, P2>, Unbounded, Order>
       where L::Root: CanSend<'a, Process<'a, P2>, In<T> = T, Out<T> = T>,
             T: Clone + Serialize + DeserializeOwned,
             Order: MinOrder<<L::Root as CanSend<'a, Process<'a, P2>>>::OutStrongestOrder<Order>, Min = Order>;
}

Required Methods§

source

fn decouple_process<P2>( self, other: &Process<'a, P2>, ) -> Stream<T, Process<'a, P2>, Unbounded, Order>
where L::Root: CanSend<'a, Process<'a, P2>, In<T> = T, Out<T> = T>, T: Clone + Serialize + DeserializeOwned, Order: MinOrder<<L::Root as CanSend<'a, Process<'a, P2>>>::OutStrongestOrder<Order>, Min = Order>,

Object Safety§

This trait is not object safe.

Implementations on Foreign Types§

source§

impl<'a, T, L: Location<'a> + NoTick, B, Order> DecoupleProcessStream<'a, T, L, B, Order> for Stream<T, L, B, Order>

source§

fn decouple_process<P2>( self, other: &Process<'a, P2>, ) -> Stream<T, Process<'a, P2>, Unbounded, Order>
where L::Root: CanSend<'a, Process<'a, P2>, In<T> = T, Out<T> = T>, T: Clone + Serialize + DeserializeOwned, Order: MinOrder<<L::Root as CanSend<'a, Process<'a, P2>>>::OutStrongestOrder<Order>, Min = Order>,

Implementors§