2017-01-08 6 views
4

Я использую RxJava 1 в течение некоторого времени, но я хочу посмотреть на RxJava 2. В RxJava 1, я мог бы излучать каждый элемент списка выглядит следующим образом:Свести список в RxJava 2

List<String> list = ... 
Observable.from(list) 
    .filter(str -> str.contains("Help") 
    .subscribe(...); 

Однако, как я могу достичь того же с RxJava2? Я пытался использовать следующее, но я не могу пройти следующее:

Observable.fromArray(list) 
// this now passes a list into the stream - there is no Observable::from 

ответ

13

Вы должны использовать fromIterable() поскольку любое List<T> расширяет Collection<T>, который проходит Iterable<T>

Observable.fromIterable(list) 
      .filter(str -> str.contains("Help") 
      .subscribe(...); 
Смежные вопросы