Преобразование наблюдаемых в RxJava и RxScala

У меня есть Observable, который выдает список записей, как показано ниже:

val obsList: Observable[List[MyEntry] = Observable.from(getListEntry)

// getListEntry would give me a List[MyEntry]

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

Observable[MyEntry]

person joesan    schedule 23.11.2015    source источник
comment
Какую версию вы используете? Observable.from(getListEntry) должен вернуть Observable [MyEntry].   -  person zsxwing    schedule 26.11.2015


Ответы (1)


Я понял, как это сделать! Я использую библиотеку Monifu!

Итак, я бы сделал:

Observable.fromIterable(listOfEntry)
person joesan    schedule 26.11.2015
comment
Почему бы не попробовать RxScala? :) - person zsxwing; 26.11.2015
comment
Библиотека Monifu уже использовалась в нашем системном ландшафте, поэтому мне пришлось ее использовать! Есть ли в библиотеке RxScala обратное давление? - person joesan; 30.11.2015
comment
Да, RxScala — это оболочка RxJava, а RxJava поддерживает обратное давление. - person zsxwing; 01.12.2015
comment
OnNext в Monifu выглядит примерно так: def onNext(elem: T): Future[Ack], но RxScala возвращает Unit? - person joesan; 02.12.2015