Πώς μπορεί να πραγματοποιηθεί η μετατροπή μιας ροής αντικειμένων σε μια άλλη ροή δεδομένων στη βιβλιοθήκη RxJava;

Στο RxJava, για τη μετατροπή ενός ρεύματος αντικειμένων σε άλλο, χρησιμοποιείται ο χειριστής map. Αυτό δέχεται μια συνάρτηση που μετατρέπει κάθε στοιχείο του αρχικού ρεύματος σε ένα νέο στοιχείο διαφορετικού τύπου.

Παράδειγμα:

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

Observable<String> strings = numbers.map(number -> "Αριθμός: " + number);

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

Ως αποτέλεσμα, στην κονσόλα θα εμφανιστεί:

Αριθμός: 1
Αριθμός: 2
Αριθμός: 3

Εκτός από το map, υπάρχουν και άλλοι χειριστές για τη μετατροπή ρευμάτων, όπως το flatMap για εργασία με εμφωλευμένα ρεύματα.