W zeszłym tygodniu opisałem przypadek użycia niestandardowego Stream Collector. Otrzymałem intrygujący komentarz na Twitterze:

Czapki z głów, Miguel! Twój komentarz ujawnił metodę, której nie znałem!

Postanowiłem więc zbadać, na czym polega ta teeing()metoda.

Zwraca Collector, który jest złożeniem dwóch kolektorów podrzędnych. Każdy element przekazany do powstałego kolektora jest przetwarzany przez oba kolektory niższego rzędu, a następnie ich wyniki są scalane przy użyciu określonej funkcji scalania w końcowy wynik.

Wynikowe funkcje kolektora wykonują następujące czynności:

* dostawca: tworzy pojemnik z wynikami, który zawiera pojemniki z wynikami uzyskane przez wywołanie dostawcy każdego kolektora

* akumulator: wywołuje każdy akumulator kolektora z jego pojemnikiem wynikowym i elementem wejściowym

* sumator: wywołuje sumator każdego kolektora z dwoma kontenerami wyników

* finisher: wywołuje finisher każdego kolektora z jego kontenerem wyników, a następnie wywołuje dostarczone połączenie i zwraca wynik.

— JavaDocs

Możemy rzeczywiście zastąpić nasz zwyczaj Collectordwiema prostymi Collectorimplementacjami, jedną agregującą wiersze cen, a drugą sumującą cenę koszyka.

Przyjrzyjmy się końcowemu kodowi i wyjaśnijmy go linijka po linijce.

public PriceAndRows getPriceAndRows(Cart cart) {
  return cart.getProducts()
      .entrySet()
      .stream()
      .map(CartRow::new)                           // 1
      .collect(Collectors.teeing(                  // 2
          Collectors.reducing(                     // 3
              BigDecimal.ZERO,                     // 4
              CartRow::getRowPrice,                // 5
              BigDecimal::add),                    // 6
          Collectors.toList(),                     // 7
          PriceAndRows::new                        // 8
      ));
}

1. Wywołaj teeing()metodę
2. Pierwszy kolekcjoner oblicza cenę. To proste reducing()połączenie z:
3. Element początkowy
4. Funkcja wyodrębniania a Pricez aCartRow
5. A BinaryOperatordodać dwie ceny razem
6. Drugi kolektor agreguje dane CartRoww listę
7. Wreszcie ostatni parametr tworzy nowy obiekt, który agreguje wyniki z pierwszego i drugiego kolektora

1. Wyodrębnia każdy z poszczególnych składników obu Collector, tj , supplier(), `accumulator()icombiner()finisher()
2. Łączy je obok siebie
3. Tworzy jedną nową Collector, przekazując pary

Mam nadzieję, że ten post skłonił Cię do rozważenia użycia teeing() przed utworzeniem niestandardowego Collector. Jeszcze raz dziękuję Miguelowi!

Swoją drogą zawsze chętnie uczę się nowych rzeczy. Jeśli chcesz podzielić się spostrzeżeniami, możesz skorzystać z poniższego systemu komentowania lub Twittera.

Pełny kod źródłowy tego posta można znaleźć na Github w formacie Maven.

Iść dalej:

• Rzeczywisty przykład kolektora strumieniowego
• Kolektory niestandardowe w Javie 8
• Trójnik Javadoc