Searched refs:ReducingSink (Results 1 – 1 of 1) sorted by relevance
72 class ReducingSink extends Box<U> implements AccumulatingSink<T, U, ReducingSink> { in makeRef() class84 public void combine(ReducingSink other) { in makeRef()88 return new ReduceOp<T, U, ReducingSink>(StreamShape.REFERENCE) { in makeRef()90 public ReducingSink makeSink() { in makeRef()91 return new ReducingSink(); in makeRef()107 class ReducingSink108 implements AccumulatingSink<T, Optional<T>, ReducingSink> {133 public void combine(ReducingSink other) {138 return new ReduceOp<T, Optional<T>, ReducingSink>(StreamShape.REFERENCE) {140 public ReducingSink makeSink() {[all …]