Trait hydro_std::compartmentalize::PartitionStream

pub trait PartitionStream<'a, T, C1, C2, Order> {
    // Required method
    fn send_partitioned<Tag, F: Fn((ClusterId<C2>, T)) -> (ClusterId<C2>, T) + 'a>(
        self,
        other: &Cluster<'a, C2>,
        dist_policy: impl IntoQuotedMut<'a, F, Cluster<'a, C1>>,
    ) -> Stream<T, Cluster<'a, C2>, Unbounded, NoOrder>
       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>, Min = NoOrder>;
}

Required Methods

fn send_partitioned<Tag, F: Fn((ClusterId<C2>, T)) -> (ClusterId<C2>, T) + 'a>( self, other: &Cluster<'a, C2>, dist_policy: impl IntoQuotedMut<'a, F, Cluster<'a, C1>>, ) -> Stream<T, Cluster<'a, C2>, Unbounded, NoOrder>

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>, Min = NoOrder>,

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl<'a, T, C1, C2, Order> PartitionStream<'a, T, C1, C2, Order> for Stream<(ClusterId<C2>, T), Cluster<'a, C1>, Unbounded, Order>

fn send_partitioned<Tag, F: Fn((ClusterId<C2>, T)) -> (ClusterId<C2>, T) + 'a>( self, other: &Cluster<'a, C2>, dist_policy: impl IntoQuotedMut<'a, F, Cluster<'a, C1>>, ) -> Stream<T, Cluster<'a, C2>, Unbounded, NoOrder>

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>, Min = NoOrder>,

Implementors