Как може да се извърши преобразуване на поток от обекти в друг поток данни в библиотеката RxJava?

В RxJava операторът map се използва за преобразуване на поток от обекти в друг. Той приема функция, която преобразува всеки елемент от изходния поток в нов елемент от друг тип.

Пример:

Observable<Integer> numbers = Observable.just(1, 2, 3);

Observable<String> strings = numbers.map(number -> "Number: " + number);

strings.subscribe(System.out::println);

В резултат в конзолата ще се изведе:

Number: 1
Number: 2
Number: 3

Освен map, съществуват и други оператори за преобразуване на потоци, като например flatMap за работа с вложени потоци.