Struct Bi 

pub struct Bi<S, A, B, P, EA, EB, F, Sc>
where
    Sc: Score,
{ /* private fields */ }

Implementations

impl<S, A, B, K, KA, KB, EA, EB, Sc> Bi<S, A, B, BiUnaryPlan<K, KA, KB>, EA, EB, TrueFilter, Sc>

where S: Send + Sync + 'static, A: Clone + Send + Sync + 'static, B: Clone + Send + Sync + 'static, K: Eq + Hash + Clone + Send + Sync, EA: CollectionExtract<S, Item = A>, EB: CollectionExtract<S, Item = B>, KA: Fn(&A) -> K + Send + Sync, KB: Fn(&B) -> K + Send + Sync, Sc: Score + 'static,

pub fn new(extractor_a: EA, extractor_b: EB, key_a: KA, key_b: KB) -> Self

impl<S, A, B, K, KA, KB, EA, EB, F, Sc> Bi<S, A, B, BiUnaryPlan<K, KA, KB>, EA, EB, F, Sc>

where S: Send + Sync + 'static, A: Clone + Send + Sync + 'static, B: Clone + Send + Sync + 'static, K: Eq + Hash + Clone + Send + Sync, EA: CollectionExtract<S, Item = A>, EB: CollectionExtract<S, Item = B>, KA: Fn(&A) -> K + Send + Sync, KB: Fn(&B) -> K + Send + Sync, F: BiFilter<S, A, B>, Sc: Score + 'static,

pub fn new_with_filter( extractor_a: EA, extractor_b: EB, key_a: KA, key_b: KB, filter: F, ) -> Self

Builds a keyed cross-bi stream with an initial joined-pair filter.

impl<S, A, B, P, EA, EB, F, Sc> Bi<S, A, B, P, EA, EB, F, Sc>

where S: Send + Sync + 'static, A: Clone + Send + Sync + 'static, B: Clone + Send + Sync + 'static, EA: CollectionExtract<S, Item = A>, EB: CollectionExtract<S, Item = B>, F: BiFilter<S, A, B>, Sc: Score + 'static,

pub fn filter<Q>( self, predicate: Q, ) -> Bi<S, A, B, P, EA, EB, AndBiFilter<F, FnBiFilter<impl Fn(&S, &A, &B, usize, usize) -> bool + Send + Sync>>, Sc>

where Q: Fn(&A, &B) -> bool + Send + Sync,

pub fn join<C, EC, P2>( self, target: (EC, P2), ) -> Tri<S, A, B, C, EA, EB, EC, P, P2, TriAsBiFilter<F, A, B>, Sc>

where C: Clone + Send + Sync + 'static, EC: CollectionExtract<S, Item = C> + 'static, P: CompileCondition + 'static, for<'a> P::Plan: ExecutablePlan<Leaf<'a, A>, Leaf<'a, B>> + IndexedPlan<Indexes: Send + Sync>, P2: CompileCondition + 'static, for<'a> P2::Plan: IndexedPlan + ExecutablePlan<Pair<Leaf<'a, A>, Leaf<'a, B>>, Leaf<'a, C>>, EA: 'static, EB: 'static,

impl<S, A, B, K, KA, KB, EA, EB, F, Sc> Bi<S, A, B, BiUnaryPlan<K, KA, KB>, EA, EB, F, Sc>

where S: Send + Sync + 'static, A: Clone + Send + Sync + 'static, B: Clone + Send + Sync + 'static, K: Eq + Hash + Clone + Send + Sync + 'static, EA: CollectionExtract<S, Item = A>, EB: CollectionExtract<S, Item = B>, KA: Fn(&A) -> K + Send + Sync, KB: Fn(&B) -> K + Send + Sync, F: BiFilter<S, A, B>, Sc: Score + 'static,

pub fn flatten_last<C, CK, Flatten, CKeyFn, ALookup>( self, flatten: Flatten, c_key_fn: CKeyFn, a_lookup_fn: ALookup, ) -> FlattenedBiConstraintStream<S, A, B, C, K, CK, EA, EB, KA, KB, Flatten, CKeyFn, ALookup, TrueFilter, Sc>

where C: Clone + Send + Sync + 'static, CK: Eq + Hash + Clone + Send + Sync, Flatten: Fn(&B) -> &[C] + Send + Sync, CKeyFn: Fn(&C) -> CK + Send + Sync, ALookup: Fn(&A) -> CK + Send + Sync,

pub fn group_by<GK, GF, C, V, R, Acc>( self, group_key_fn: GF, collector: C, ) -> Grouped<S, A, B, K, GK, EA, EB, KA, KB, F, GF, C, V, R, Acc, Sc>

where GK: Eq + Hash + Clone + Send + Sync + 'static, GF: Fn(&A, &B) -> GK + Send + Sync, C: for<'i> Collector<(&'i A, &'i B), Value = V, Result = R, Accumulator = Acc> + Send + Sync + 'static, V: Send + Sync + 'static, R: Send + Sync + 'static, Acc: Accumulator<V, R> + Send + Sync + 'static,

pub fn project<Out, Proj>( self, project: Proj, ) -> Stream<S, Out, JoinedSource<S, A, B, K, EA, EB, KA, KB, F, Proj, Out>, TrueFilter, Sc>

where Out: Send + Sync + 'static, Proj: Fn(&A, &B) -> Out + Send + Sync + 'static,

impl<S, A, B, P, EA, EB, F, Sc> Bi<S, A, B, P, EA, EB, F, Sc>

where S: Send + Sync + 'static, A: Clone + Send + Sync + 'static, B: Clone + Send + Sync + 'static, P: CompileCondition + 'static, for<'a> P::Plan: ExecutablePlan<Leaf<'a, A>, Leaf<'a, B>> + IndexedPlan<Indexes: Send + Sync>, EA: CollectionExtract<S, Item = A>, EB: CollectionExtract<S, Item = B>, F: BiFilter<S, A, B>, Sc: Score + 'static,

pub fn penalize<W>( self, weight: W, ) -> Builder<S, A, B, P, EA, EB, F, impl Fn(&A, &B) -> Sc + Send + Sync, Sc>

where W: for<'w> ConstraintWeight<(&'w A, &'w B), Sc> + Send + Sync,

pub fn reward<W>( self, weight: W, ) -> Builder<S, A, B, P, EA, EB, F, impl Fn(&A, &B) -> Sc + Send + Sync, Sc>

where W: for<'w> ConstraintWeight<(&'w A, &'w B), Sc> + Send + Sync,

Trait Implementations

impl<S, A, B, P, EA, EB, F, Sc: Score> Debug for Bi<S, A, B, P, EA, EB, F, Sc>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.