的Java 8嵌套流：在最後一個流返回值

Question

這個問題可以基於考慮java 8 nested streams

假設我有一個Batch與Basket s的Item S：

public class Batch { 
    private List<Basket> baskets; 
} 

public class Basket { 
    private List<Item> items; 
} 

public class Item { 
    private String property; 
    private int value; 
} 

我想用Java 8流重寫此方法。

public class SomeService { 
    public int findValueInBatch(Batch batch) { 
     for (Basket basket : batch.getBaskets()) { 
      for (Item item : basket.getItems()) { 
       if (item.getProperty().equals("someValue") { 
        return item.getValue(); 
       } 
      } 
     } 
     return 0; 
    } 
} 

我應該怎麼做？

第一步，我想哪裏去：

public int findValueInBatch(Batch batch) { 
    for (Basket basket : batch.getBaskets()) { 
     basket.getItems().stream() 
      .filter(item -> item.getProperty.equals("someValue") 
      .findFirst() 
      .get(); 
      // there I should 'break' 
    } 
} 

非常感謝。

Answer 1

baskets.stream() 
      .flatMap(basket -> basket.getItems().stream()) 
      .filter(item -> item.equals("someValue")) 
      .findAny() 
      .orElseThrow(NoSuchElementException::new); 

使用findAny代替findFirst是findFirst不平行流工作的優勢。因此，如果要並行執行上述操作，您只需將stream()方法替換爲parallel()

Answer 2

爲了消除這兩個循環，您可以使用flatMap生產的所有Item一切都在Basket S的的Stream<Item>：

return batch.getBaskets() 
      .stream() 
      .flatMap(b -> b.getItems().stream()) 
      .filter(item -> item.getProperty.equals("someValue")) 
      .findFirst() 
      .orElse(some default value); // using .get() would throw an exception 
             // if no match is found 

Answer 3

1. 使用flatMap得到嵌套列表的順風車，提取每個List<Item>，轉他們分成Stream<Item>，就像所有的子流合併在一起。
2. 使用filter忽略不匹配的元素。
3. 使用findFirst只得到第一次出現和停止處理
4. 使用orElseThrow拋出一個異常，如果沒有someValue中的occurence被發現。

在這裏你去

public class SomeService { 
    public int findValueInBatch(Batch batch) { 
     return batch.getBaskets().stream() 
      .flatMap(basket -> basket.getItems().stream()) 
      .filter(item -> item.getProperty.equals("someValue")) 
      .findFirst() 
      .orElseThrow(() -> new IllegalArgumentException("value not found")); 
    } 
}