как реализовать flatten для потока с помощью flatmap

Question

Как мне реализовать flatten для Stream, используя flatmap? Для функции сохранения содержимого входного потока, но упрощения его структуры в единый поток?

def flatten(ffa: Stream[Stream[A]]): 
    Stream[A]=

Answer 1

Вы можете попробовать:

def flatten[A](ffa: Stream[Stream[A]]): Stream[A] = ffa.flatMap(identity)

>flatten(Stream(Stream(1,2,3), Stream(4,5,6), Stream(7,8,9)))
// res1: Stream[Int] = Stream(1, 2, 3, 4, 5, 6, 7, 8, 9)