Lines Matching defs:downstream
85 private final TabulationAssertion<T,V> downstream;
89 TabulationAssertion<T, V> downstream) {
92 this.downstream = downstream;
103 downstream.assertValue(entry.getValue(),
145 private final TabulationAssertion<T,D> downstream;
148 TabulationAssertion<T, D> downstream) {
150 this.downstream = downstream;
159 downstream.assertValue(map.get(true), () -> source.get().filter(predicate), ordered);
160 downstream.assertValue(map.get(false), () -> source.get().filter(predicate.negate()), ordered);
487 // with concurrent as downstream
493 // with concurrent as upstream and downstream
512 // with concurrent as downstream
518 // with concurrent as upstream and downstream
579 // Single-level partition to downstream List
