Trait JoinTarget 

pub trait JoinTarget<S, A, E, F, Sc: Score> {
    type Output;

    // Required method
    fn apply(self, extractor_a: E, filter_a: F) -> Self::Output;
}

Required Associated Types

type Output

Required Methods

fn apply(self, extractor_a: E, filter_a: F) -> Self::Output

Implementations on Foreign Types

impl<S, A, B, E, F, EB, FB, P, Sc> JoinTarget<S, A, E, F, Sc> for (UniConstraintStream<S, B, EB, FB, Sc>, P)

where S: Send + Sync + 'static, A: Clone + Send + Sync + 'static, B: Clone + Send + Sync + 'static, E: CollectionExtract<S, Item = A>, F: UniFilter<S, A>, EB: CollectionExtract<S, Item = B>, FB: UniFilter<S, B>, P: Fn(&A, &B) -> bool + Send + Sync + 'static, Sc: Score + 'static,

type Output = CrossBiConstraintStream<S, A, B, u8, E, EB, fn(&A) -> u8, fn(&B) -> u8, UniLeftPredBiFilter<F, P, A>, Sc>

fn apply(self, extractor_a: E, filter_a: F) -> Self::Output

impl<S, A, B, E, F, EB, K, KA, KB, Sc> JoinTarget<S, A, E, F, Sc> for (EB, EqualJoiner<KA, KB, K>)

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

type Output = CrossBiConstraintStream<S, A, B, K, E, EB, KA, KB, UniLeftBiFilter<F, B>, Sc>

fn apply(self, extractor_a: E, filter_a: F) -> Self::Output

Implementors

impl<S, A, E, F, K, KA, Sc> JoinTarget<S, A, E, F, Sc> for EqualJoiner<KA, KA, K>

where S: Send + Sync + 'static, A: Clone + Hash + PartialEq + Send + Sync + 'static, E: CollectionExtract<S, Item = A>, F: UniFilter<S, A>, K: Eq + Hash + Clone + Send + Sync, KA: Fn(&A) -> K + Send + Sync, Sc: Score + 'static,

type Output = BiConstraintStream<S, A, K, E, EntityKeyAdapter<KA>, UniLeftBiFilter<F, A>, Sc>