Cum se poate realiza transformarea unui flux de obiecte într-un alt flux de date în biblioteca RxJava?

În RxJava, pentru a transforma un flux de obiecte într-altul, se folosește operatorul map. Acesta acceptă o funcție care transformă fiecare element al fluxului original într-un element nou de alt tip.

Exemplu:

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

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

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

Ca rezultat, în consolă se va afișa:

Număr: 1
Număr: 2
Număr: 3

Pe lângă map, există și alți operatori pentru transformarea fluxurilor, precum flatMap pentru lucrul cu fluxuri imbricate.