Kaip galima atlikti vieno objektų srauto transformaciją į kitą duomenų srautą RxJava bibliotekoje?

RxJava, map operatorius naudojamas vieno srauto objektų konvertavimui į kitą. Jis priima funkciją, kuri kiekvieną pradinio srauto elementą paverčia nauju kitu tipu.

Pavyzdys:

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

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

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

Rezultatas konsolėje bus:

Numeris: 1
Numeris: 2
Numeris: 3

Be map, yra ir kitų operatorių, skirtų srautų transformacijai, pavyzdžiui, flatMap, kuris dirba su įdėtais srautais.