RxJava 是一個基于事件流的響應式編程庫，可以讓你更方便地處理異步操作和數據轉換

1. 添加 RxJava 依賴：

在你的項目的 build.gradle 文件中添加以下依賴：

dependencies {
    implementation 'io.reactivex.rxjava3:rxjava:3.x.y'
}

將 x.y 替換為最新的版本號。

2. 創建 Observable：

Observable 是 RxJava 中的核心類型，代表一個可觀察的數據流。你可以使用 Observable.create() 方法創建一個 Observable：

import io.reactivex.rxjava3.core.Observable;
import io.reactivex.rxjava3.core.ObservableEmitter;
import io.reactivex.rxjava3.core.ObservableOnSubscribe;

public class Main {
    public static void main(String[] args) {
        Observable<Integer> observable = Observable.create(new ObservableOnSubscribe<Integer>() {
            @Override
            public void subscribe(ObservableEmitter<Integer> emitter) throws Throwable {
                for (int i = 1; i <= 5; i++) {
                    emitter.onNext(i);
                }
                emitter.onComplete();
            }
        });
    }
}

3. 使用操作符進行數據轉換：

RxJava 提供了許多操作符，可以方便地對數據流進行轉換。例如，你可以使用 map() 操作符將 Integer 類型的數據轉換為 String 類型：

import io.reactivex.rxjava3.core.Observable;
import io.reactivex.rxjava3.core.ObservableEmitter;
import io.reactivex.rxjava3.core.ObservableOnSubscribe;

public class Main {
    public static void main(String[] args) {
        Observable<Integer> observable = Observable.create(new ObservableOnSubscribe<Integer>() {
            @Override
            public void subscribe(ObservableEmitter<Integer> emitter) throws Throwable {
                for (int i = 1; i <= 5; i++) {
                    emitter.onNext(i);
                }
                emitter.onComplete();
            }
        });

        Observable<String> stringObservable = observable.map(new Function<Integer, String>() {
            @Override
            public String apply(Integer integer) throws Throwable {
                return "Number: " + integer;
            }
        });
    }
}

4. 訂閱并觀察數據流：

要開始觀察數據流，你需要訂閱 Observable。訂閱時，你需要提供一個 Observer 來處理數據流中的數據和事件：

import io.reactivex.rxjava3.core.Observer;
import io.reactivex.rxjava3.disposables.Disposable;

// ...

stringObservable.subscribe(new Observer<String>() {
    @Override
    public void onSubscribe(Disposable d) {
        System.out.println("Subscribed");
    }

    @Override
    public void onNext(String s) {
        System.out.println(s);
    }

    @Override
    public void onError(Throwable e) {
        e.printStackTrace();
    }

    @Override
    public void onComplete() {
        System.out.println("Completed");
    }
});

運行這段代碼，你將看到以下輸出：

Subscribed
Number: 1
Number: 2
Number: 3
Number: 4
Number: 5
Completed

這就是在 Java 中使用 RxJava 進行數據轉換的基本過程。你可以根據需要使用更多的操作符來處理復雜的數據流。