Trait hydro_std::compartmentalize::DecoupleClusterStream

source · 
pub trait DecoupleClusterStream<'a, T, C1, B, Order> {
    // Required method
    fn decouple_cluster<C2: 'a, Tag>(
        self,
        other: &Cluster<'a, C2>,
    ) -> Stream<T, Cluster<'a, C2>, Unbounded, Order>
       where Cluster<'a, C1>: Location<'a, Root = Cluster<'a, C1>> + CanSend<'a, Cluster<'a, C2>, In<T> = (ClusterId<C2>, T), Out<T> = (Tag, T)>,
             T: Clone + Serialize + DeserializeOwned,
             Order: MinOrder<<Cluster<'a, C1> as CanSend<'a, Cluster<'a, C2>>>::OutStrongestOrder<Order>>;
}

Required Methods§

source

fn decouple_cluster<C2: 'a, Tag>( self, other: &Cluster<'a, C2>, ) -> Stream<T, Cluster<'a, C2>, Unbounded, Order>
where Cluster<'a, C1>: Location<'a, Root = Cluster<'a, C1>> + CanSend<'a, Cluster<'a, C2>, In<T> = (ClusterId<C2>, T), Out<T> = (Tag, T)>, T: Clone + Serialize + DeserializeOwned, Order: MinOrder<<Cluster<'a, C1> as CanSend<'a, Cluster<'a, C2>>>::OutStrongestOrder<Order>>,

Object Safety§

This trait is not object safe.

Implementations on Foreign Types§

source§

impl<'a, T, C1, B, Order> DecoupleClusterStream<'a, T, C1, B, Order> for Stream<T, Cluster<'a, C1>, B, Order>

source§

fn decouple_cluster<C2: 'a, Tag>( self, other: &Cluster<'a, C2>, ) -> Stream<T, Cluster<'a, C2>, Unbounded, Order>
where Cluster<'a, C1>: Location<'a, Root = Cluster<'a, C1>> + CanSend<'a, Cluster<'a, C2>, In<T> = (ClusterId<C2>, T), Out<T> = (Tag, T)>, T: Clone + Serialize + DeserializeOwned, Order: MinOrder<<Cluster<'a, C1> as CanSend<'a, Cluster<'a, C2>>>::OutStrongestOrder<Order>>,

Implementors§