Преобразовать Observable <List <Car>> в последовательность Observable <Car> в RxJava
Учитывая список автомобилей (List<Car> cars
), я могу сделать:
Observable.just(cars); //returns an Observable that emits one List<Car>
Observable.from(cars); //returns an Observable that emits a squence of Car
Есть ли способ перейти от Observable
к List<Car>
к последовательности Observable<Car>
?
Что-то вроде from
без параметров
Obserable.just(cars).from()
Ответы
Ответ 1
Вы можете сопоставить Observable<List<Car>>
с Observable<Car>
следующим образом:
yourListObservable.flatMapIterable(x -> x)
Обратите внимание, что flatMapping может не сохранять порядок наблюдаемого источника. Если порядок concatMapIterable
для вас, используйте concatMapIterable
. Читайте здесь для более подробной информации.
Ответ 2
Вы можете использовать это
flatMap { t -> Observable.fromIterable(t) }