Jak iterować zagnieżdżone dla pętli odwołujących się do elementów nadrzędnych za pomocą strumieni Java 8?

Question

Chcę iterować zagnieżdżone listy przy użyciu java8 streams i wyodrębnić niektóre wyniki z list na pierwszym dopasowaniu. Niestety muszę również uzyskać wartości z treści nadrzędnej, jeśli element podrzędny pasuje do filtru.

Jak mogę to zrobić?

// java7

Result result = new Result(); 

//find first match and pupulate the result object. 
for (FirstNode first : response.getFirstNodes()) { 
    for (SndNode snd : first.getSndNodes()) { 
     if (snd.isValid()) { 
      result.setKey(first.getKey()); 
      result.setContent(snd.getContent()); 
      return; 
     } 
    } 
} 

// java8

response.getFirstNodes().stream() 
     .flatMap(first -> first.getSndNodes()) 
     .filter(snd -> snd.isValid()) 
     .findFirst() 
     .ifPresent(???); //cannot access snd.getContent() here 

Answer 1

Kiedy trzeba obie wartości i chcą korzystać flatMap (wymagane, gdy chcesz przeprowadzić operację zwarciem jak findFirst), trzeba mapować obiekt trzymając obie wartości

response.getFirstNodes().stream() 
    .flatMap(first->first.getSndNodes().stream() 
    .map(snd->new AbstractMap.SimpleImmutableEntry<>(first, snd))) 
    .filter(e->e.getValue().isValid()) 
    .findFirst().ifPresent(e-> { 
    result.setKey(e.getKey().getKey()); 
    result.setContent(e.getValue().getContent()); 
    }); 

Aby używać wyłącznie klas standardowych, używam Map.Entry jako typu Pair, podczas gdy prawdziwy typ Pair może wyglądać bardziej zwięźle.

W tym konkretnym przypadku zastosowania, można przejść operację filtra do strumienia wewnętrznego

response.getFirstNodes().stream() 
    .flatMap(first->first.getSndNodes().stream() 
    .filter(snd->snd.isValid()) 
    .map(snd->new AbstractMap.SimpleImmutableEntry<>(first, snd))) 
    .findFirst().ifPresent(e-> { 
    result.setKey(e.getKey().getKey()); 
    result.setContent(e.getValue().getContent()); 
    }); 

który ma estetyczny efekt, że tylko do jednego elementu dopasowującego, instancja Map.Entry zostanie utworzony (dobrze, powinno być jako the current implementation is not as lazy as it should, ale nawet wtedy nadal będzie tworzyć mniejsze obiekty niż w pierwszym wariancie).

Answer 2

Powinno być tak:

Edit: Dzięki Holger za wskazanie, że kod nie zatrzyma się na pierwszy prawidłowy FirstNode

response.getFirstNodes().stream() 
    .filter(it -> {it.getSndNodes().stream().filter(SndNode::isValid).findFirst(); return true;}) 
    .findFirst() 
    .ifPresent(first -> first.getSndNodes().stream().filter(SndNode::isValid).findFirst().ifPresent(snd -> { 
    result.setKey(first.getKey()); 
    result.setContent(snd.getContent()); 
    })); 

Test można znaleźć here