Ako možno v knižnici RxJava vykonať transformáciu jedného toku objektov na iný tok údajov?

V RxJava sa používa operátor map na transformáciu jedného prúdu objektov na iný. Prijíma funkciu, ktorá transformuje každý prvok pôvodného prúdu na nový prvok iného typu.

Príklad:

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

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

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

Ako výsledok sa na konzole vypíše:

Číslo: 1
Číslo: 2
Číslo: 3

Okrem map existujú aj iné operátory na transformáciu prúdov, napríklad flatMap na prácu s vnorenými prúdmi.