如何使用Room和RxJava插入数据？

dependencies {
    implementation "androidx.room:room-runtime:2.4.0"
    implementation "androidx.room:room-rxjava3:2.4.0"
    implementation "io.reactivex.rxjava3:rxjava:3.0.0"
}

@Entity
public class User {
    @PrimaryKey
    public int id;
    
    public String name;
}

@Dao
public interface UserDao {
    @Insert
    Completable insertUser(User user);
}

@Database(entities = {User.class}, version = 1)
public abstract class AppDatabase extends RoomDatabase {
    public abstract UserDao userDao();
}

public class MyApp extends Application {
    public static AppDatabase database;
    
    @Override
    public void onCreate() {
        super.onCreate();
        database = Room.databaseBuilder(getApplicationContext(), AppDatabase.class, "my-db").build();
    }
}

User user = new User();
user.id = 1;
user.name = "John Doe";

MyApp.database.userDao().insertUser(user)
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(new CompletableObserver() {
        @Override
        public void onSubscribe(@NonNull Disposable d) {
            // 可选的订阅时操作
        }

        @Override
        public void onComplete() {
            // 插入数据成功
        }

        @Override
        public void onError(@NonNull Throwable e) {
            // 插入数据失败
        }
    });