Pętle zagnieżdżone Java 8 do strumienia

Question

Próbuję opanować składnię strumienia w języku Java 8 za pomocą prostego przykładu. Przyjrzałam się innym podobnym pytaniom na ten temat, ale nie mogłem znaleźć rozwiązań, które pasowałyby do mojego przykładu i działałyby dla mnie. Zasadniczo próbuję byłaby następujący fragment z dwóch zagnieżdżonych pętli do korzystania z nowego strumienia API:

List<Car> filteredCars = new ArrayList<>(); 
    for (Car car : cars) { 

     for (Wheel wheel : wheels) { 

      if (car.getColor() == wheel.getColor() && 
        wheel.isWorking() == true) { 

       filteredCars.add(car); 
       break; 
      } 
     } 
    } 

    return filteredCars; 

Zarządzane wymyślić ten, który zwraca void:

return cars.stream().forEach(
      car -> wheels.stream() 
      .filter(wheel -> wheel.getColor() == car.getColor() && 
        wheel.isWorking() == true) 
      .collect(Collectors.toList())); 

Co jest nie tak ze strumieniem powyższa składnia i czego mi brakuje?

Answer 1

Nie można wykonać dwóch operacji terminalowych - forEach i collect na tym samym Stream.

zamiast tego trzeba filtrować listę samochodów sprawdzanie każdego samochodu, jeśli ma pasujący kołem obrotowym:

List<Car> filteredCars = 
    cars.stream() 
     .filter (
      car -> wheels.stream() 
         .anyMatch(wheel -> wheel.getColor() == car.getColor() &&  
              wheel.isWorking())) 
     .collect(Collectors.toList()); 

Answer 2

Problem polega na tym, jesteś tworząc List (y) wewnątrz forEach i forEach zwraca void. Byłaby to równoważna z następujących pętli:

for (Car car : cars) { 
    List<Car> filteredCars = new ArrayList<>(); 
    for (Wheel wheel : wheels) { 

     if (car.getColor() == wheel.getColor() && 
       wheel.isWorking() == true) { 

      filteredCars.add(car); 
      break; 
     } 
    } 
} 

return filteredCars; // whoops cannot be accessed (scope) !!! 

można użyć filter w strumieniu cars i zbierania zastosowanie collect na przefiltrowanego strumienia, aby osiągnąć pożądane wyniki:

Predicate<Car> carCheck = car -> wheels.stream().anyMatch(wheel -> car.getColor() == wheel.getColor() && wheel.isWorking()); 

List<Car> filteredCars = cars.stream().filter(carCheck).collect(Collectors.toList());