Struct ProjectedConstraintStream 

pub struct ProjectedConstraintStream<S, Out, Src, F, Sc>
where
    Sc: Score,
{ /* private fields */ }

Implementations

impl<S, Out, Src, F, Sc> ProjectedConstraintStream<S, Out, Src, F, Sc>

where S: Send + Sync + 'static, Out: Send + Sync + 'static, Src: ProjectedSource<S, Out>, F: UniFilter<S, Out>, Sc: Score + 'static,

pub fn filter<P>( self, predicate: P, ) -> ProjectedConstraintStream<S, Out, Src, AndUniFilter<F, FnUniFilter<impl Fn(&S, &Out) -> bool + Send + Sync>>, Sc>

where P: Fn(&Out) -> bool + Send + Sync + 'static,

pub fn merge<OtherSrc, OtherF>( self, other: ProjectedConstraintStream<S, Out, OtherSrc, OtherF, Sc>, ) -> ProjectedConstraintStream<S, Out, MergedProjectedSource<FilteredProjectedSource<S, Out, Src, F>, FilteredProjectedSource<S, Out, OtherSrc, OtherF>>, TrueFilter, Sc>

where OtherSrc: ProjectedSource<S, Out>, OtherF: UniFilter<S, Out>,

pub fn group_by<K, KF, C>( self, key_fn: KF, collector: C, ) -> ProjectedGroupedConstraintStream<S, Out, K, Src, F, KF, C, Sc>

where K: Eq + Hash + Send + Sync + 'static, KF: Fn(&Out) -> K + Send + Sync, C: UniCollector<Out> + Send + Sync + 'static, C::Accumulator: Send + Sync, C::Value: Send + Sync, C::Result: Send + Sync,

pub fn join<K, KF>( self, joiner: EqualJoiner<KF, KF, K>, ) -> ProjectedBiConstraintStream<S, Out, K, Src, F, KF, TrueFilter, Sc>

where K: Eq + Hash + Send + Sync + 'static, KF: Fn(&Out) -> K + Send + Sync,

pub fn penalize_hard_with<W>( self, weight: W, ) -> ProjectedConstraintBuilder<S, Out, Src, F, W, Sc>

where W: Fn(&Out) -> Sc + Send + Sync,

pub fn penalize_with<W>( self, weight: W, ) -> ProjectedConstraintBuilder<S, Out, Src, F, W, Sc>

where W: Fn(&Out) -> Sc + Send + Sync,