Trait hydro_std::compartmentalize::PartitionStream
source · 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.