Как регистрировать отфильтрованные значения в потоках Java

У меня есть требование log/sysout отфильтрованных значений в потоках Java. Я могу log/sysout значение с помощью метода peek(). Однако, может кто-нибудь, пожалуйста, дайте мне знать, как регистрировать отфильтрованные значения?

Например, допустим, у меня есть список объектов Person например:

List<Person> persons = Arrays.asList(new Person("John"), new Person("Paul"));

Я хочу отфильтровать тех людей, которые не являются "Джоном", следующим образом:

persons.stream().filter(p -> !"John".equals(p.getName())).collect(Collectors.toList());

Тем не менее, я должен зарегистрировать детали этого человека "Джон", который фильтруется. Может кто-то, пожалуйста, помогите мне достичь этого?

Ответ 1

Если вы хотите интегрировать его с Stream API, вы не можете сделать ничего, кроме введения журнала вручную. Самый безопасный способ - ввести регистрацию в самом методе filter():

List<Person> filtered = persons.stream()
      .filter(p -> {
          if (!"John".equals(p.getName())) {
              return true;
          } else {
              System.out.println(p.getName());
              return false;
          }})
      .collect(Collectors.toList());

Имейте в виду, что введение побочных эффектов в Stream API является теневым, и вам нужно знать, что вы делаете.

Вы также можете создать общее оберточное решение:

private static <T> Predicate<T> andLogFilteredOutValues(Predicate<T> predicate) {
    return value -> {
        if (predicate.test(value)) {
            return true;
        } else {
            System.out.println(value);
            return false;
        }
    };
}

а затем просто:

List<Person> persons = Arrays.asList(new Person("John"), new Person("Paul"));

List<Person> filtered = persons.stream()
  .filter(andLogFilteredOutValues(p -> !"John".equals(p.getName())))
  .collect(Collectors.toList());

... или даже сделать действие настраиваемым:

private static <T> Predicate<T> andLogFilteredOutValues(Predicate<T> predicate, Consumer<T> action) {
    Objects.requireNonNull(predicate);
    Objects.requireNonNull(action);

    return value -> {
        if (predicate.test(value)) {
            return true;
        } else {
            action.accept(value);
            return false;
        }
    };
}

затем:

List<Person> filtered = persons.stream()
  .filter(andLogFilteredOutValues(p -> !"John".equals(p.getName()), System.out::println))
  .collect(Collectors.toList());

Ответ 2

Вы можете использовать

Map<Boolean,List<Person>> map = persons.stream()
    .collect(Collectors.partitioningBy(p -> "John".equals(p.getName())));
System.out.println("filtered: " + map.get(true));
List<Person> result = map.get(false);

или, если вы предпочитаете одну форму:

List<Person> result = persons.stream()
    .collect(Collectors.collectingAndThen(
        Collectors.partitioningBy(p -> "John".equals(p.getName())),
        map -> {
            System.out.println("filtered: " + map.get(true));
            return map.get(false);
        }));

Ответ 3

Поскольку нет способа запуска действий терминала над элементами, сопоставляющими противоположные фильтры в одном и том же потоке, лучшим вариантом может быть просто использование условия для потребителя peek.

Это позволяет избежать пересечения потока/коллекции дважды.

List<Person> persons = Arrays.asList(new Person("John"), new Person("Paul"));

//A consumer that only logs "John" persons
Consumer<Person> logger = p -> {
    if ("John".equals(p.getName())) //condition in consumer
        System.out.println("> " + p.getName());
};

Затем мы можем передать этого потребителя peek, только после этого фильтруя для окончательного действия:

List<Person> nonJohns = persons.stream()
                  .peek(logger)
                  .filter(p -> !"John".equals(p.getName()))
                  .collect(Collectors.toList());