Kako se u biblioteci RxJava može izvršiti transformacija jednog toka objekata u drugi tok podataka?

U RxJava, operator map se koristi za transformaciju jednog toka objekata u drugi. On prihvata funkciju koja transformiše svaki element izvornog toka u novi element drugog tipa.

Primer:

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

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

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

Kao rezultat, u konzoli će se prikazati:

Broj: 1
Broj: 2
Broj: 3

Pored map, postoje i drugi operatori za transformaciju tokova, kao što je flatMap za rad sa ugnježdenim tokovima.