@ Override public < T > Streamlet < T > flatMap ( SerializableFunction < R , ? extends Iterable < ? extends T > > flatMapFn ) { checkNotNull ( flatMapFn , "flatMapFn cannot be null" ) ; FlatMapStreamlet < R , T > retval = new FlatMapStreamlet <> ( this , flatMapFn ) ; addChild ( retval ) ; return retval ; }
Return a new Streamlet by applying flatMapFn to each element of this Streamlet and flattening the result