Stream APIにflatten（）メソッドがないのはなぜですか？

Question

次の2つのコードスニペットで同じ結果が得られます。 flatMapで

：

identityを使用して flatMap続い mapで

Stream.iterate(2, n -> n + 4) 
      .flatMap(n -> Stream.of(n, -(n + 2))); 

：

Stream.iterate(2, n -> n + 4) 
      .map(n -> Stream.of(n, -(n + 2))) 
      .flatMap(Function.identity()); 

だから、（Scalaの中のようなStreamインターフェースで引数なしのflatten方法が含まれるように、自然と思われますStream）、前の例を次のように書くことができます。

Stream.iterate(2, n -> n + 4) 
      .map(n -> Stream.of(n, -(n + 2))) 
      .flatten(); 

Stream APIにはなぜflatten()メソッドがありませんか？

Answer 1

flattenメソッドをJavaで実装できませんでした。 Stream<? extends Stream<?>>でのみ呼び出し可能ですが、Rの場合はT extends Stream<R>かどうかを判断する方法はありません。

あなたはScalaではメソッドのシグネチャを見れば：

def flatten[B](implicit asTraversable: (A) ⇒ GenTraversableOnce[B]): Stream[B] 

それは実際にタイプAは、いくつかのタイプBの集まりである暗黙の証拠パラメータを取ります。

JavaでflatMap方法が機能T -> Stream<? extends R>を取ります

<R> Stream<R> flatMap(Function<? super T,? extends Stream<? extends R>> mapper) 

だから我々はそれがStream<R>に平坦化することができることを知っています。

flattenの静的な実装が可能です：

static <R> Stream<R> flatten(Stream<? extends Stream<? extends R>> stream) { 
    return stream.flatMap(Function.identity()); 
}