see streams #flatmap publisher , function . concode_field_sep PlaceHolder placeHolder concode_field_sep Promise<R> reduce concode_elem_sep Promise<List<T>> toList concode_elem_sep TransformablePublisher<T> multicast concode_elem_sep Promise<T> toPromise concode_elem_sep TransformablePublisher<T> filter concode_elem_sep TransformablePublisher<O> transform concode_elem_sep TransformablePublisher<T> fork concode_elem_sep TransformablePublisher<T> fork concode_elem_sep TransformablePublisher<O> streamMap concode_elem_sep TransformablePublisher<O> streamMap concode_elem_sep TransformablePublisher<T> wiretap concode_elem_sep TransformablePublisher<T> bindExec concode_elem_sep TransformablePublisher<T> bindExec concode_elem_sep TransformablePublisher<T> buffer concode_elem_sep TransformablePublisher<T> gate concode_elem_sep TransformablePublisher<O> map
TransformablePublisher < O > function ( Function < ? super T , ? extends Promise < ? extends O >> arg0 ) { return Streams . flatMap ( this , arg0 ) ; }