Предполагая, что у меня есть наблюдаемое и где-то ниже по течению, я решил фильтровать с использованием потоков java 8 вместо использования операторов rxjava. Это вызовет какие-либо проблемы?
List<String> stringList = new ArrayList<>();
Observable.just(stringList)
.map(new Function<List<String>, List<String>>() {
@Override
public List<String> apply(List<String> strings) throws Exception {
return strings.stream().filter(it -> it.contains("randomText"))
.collect(Collectors.toList());
}
}).subscribe(new Consumer<List<String>>() {
@Override
public void accept(List<String> strings) throws Exception {
//do something with list
}
});




Consumer<T> принимает T, поэтому вы можете использовать все методы, предоставляемые T.
В любом случае проверьте документация, RxJava предоставляет несколько операторов, таких как map, flatMap, filter и т. д. Например, вы можете заменить в своем коде первый map следующим образом:
Observable.fromIterable(stringList).filter(x -> x.contains(RANDOM_TEXT))
почему вы используете здесь RxJava? Вы можете написать простое предложение потока Java, например stringList.stream().filter() и т. д.