可以封裝中間流操作而不破壞流水線嗎？

Question

使用Java 8 Streams，是否有可能以某種不會中斷流管道的方式封裝和重用中間流操作？

考慮這個例子從Java Tutorial on streams：

double average = roster 
    .stream() 
    .filter(p -> p.getGender() == Person.Sex.MALE) 
    .mapToInt(Person::getAge) 
    .average() 
    .getAsDouble(); 

想我需要用在不同的地方濾波器和mapToInt業務遍及我的代碼。我可能要嘗試來封裝邏輯，所以它可以重複使用，例如：

IntStream maleAges(Stream<Person> stream) { 
    return stream 
     .filter(p -> p.getGender() == Person.Sex.MALE) 
     .mapToInt(Person::getAge) 
} 

這是很好的，但使用它我有可能使流管道的一個爛攤子。例如，如果我想要名爲Bob的男性的平均年齡：

double averageBob = 
    maleAges(roster 
     .stream() 
     .filter(p -> "Bob".equals(p.getName())) 
    ) 
    .average() 
    .getAsDouble(); 

有沒有更好的方法來做到這一點？我沿着這些線路的思維了一句：

double averageBob = roster 
    .stream() 
    .filter(p -> "Bob".equals(p.getName())) 
    .apply(this::maleAges) // Doesn't compile 
    .average() 
    .getAsDouble(); 

Answer 1

我StreamEx庫，增強了其他功能的標準流API具有chain方法，你提出的apply它的工作原理完全：

double averageBob = StreamEx.of(roster) 
     .filter(p -> "Bob".equals(p.getName())) 
     .chain(this::maleAges) // Compiles! 
     .average() 
     .getAsDouble(); 

另外一個可能的選擇是從maleAges返回一個函數：

Function<Stream<Person>, IntStream> maleAges() { 
    return stream -> stream 
     .filter(p -> p.getGender() == Person.Sex.MALE) 
     .mapToInt(Person::getAge); 
} 

並使用它是這樣的：

double averageBob = StreamEx.of(roster) 
     .filter(p -> "Bob".equals(p.getName())) 
     .chain(maleAges()) // Compiles! 
     .average() 
     .getAsDouble(); 

這樣你可以很容易地參數化你的封裝操作。例如：

Function<Stream<Person>, IntStream> agesForSex(Person.Sex sex) { 
    return stream -> stream 
     .filter(p -> p.getGender() == sex) 
     .mapToInt(Person::getAge); 
} 

double averageBob = StreamEx.of(roster) 
     .filter(p -> "Bob".equals(p.getName())) 
     .chain(agesForSex(Person.Sex.MALE)) // Compiles! 
     .average() 
     .getAsDouble(); 

Answer 2

一種方式做這將是代替接受流，採取單人，併發出IntStream如：

final Predicate<Person> isMale = p -> p.getGender() == Person.Sex.MALE; 
final Function<Person, IntStream> maleAges = person -> isMale.test(person) 
      ? IntStream.of(person.age) 
      : IntStream.empty(); 
final double averageT = roster 
       .stream() 
       .flatMapToInt(maleAges) 
       .average() 
       .getAsDouble(); 

這您可以隨時隨地重複使用您的maleAges功能！