Каким образом можно осуществить преобразование одного потока объектов в другой поток данных в библиотеке RxJava?