代码之家 › 专栏 › 技术社区 › Rasoul Miri

rx java obsever pojo模型的变化

rx-java2 android java

-4

Rasoul Miri · 技术社区 · 7 年前

见样品

public class User {
     String firstName;
     String latsName;
}

和

public void main(){
    User user = new User();
    user.setFirstName("rasoul");

    //detect change by rxJava or Rx android

}

我需要使用rxjava来检测用户模型的变化

2 回复 | 直到 7 年前

EpicPandaForce Jigar Joshi 7 年前

你需要让你的模型可以观察到变化。

public class User {
     public interface ChangeListener {
         void onChanged(User user);
     }

     private List<ChangeListener> changeListeners = new CopyOnWriteArrayList<>();

     public void addChangeListener(ChangeListener listener) {
         this.changeListeners.add(listener);
     }

     public void removeChangeListener(ChangeListener listener) {
         this.changeListeners.remove(listener);
     }

     private String firstName;
     private String lastName;

     public void setFirstName(String firstName) {
         this.firstName = firstName;
         for(ChangeListener changeListener: changeListeners) {
             changeListener.onChanged(this);
         }
     }
}

因为现在你可以观察一个用户:

user.addChangeListener((u) -> {
    // user changed
});

现在你可以很容易地把它包装成可观察的:

public class RxUser {
    private RxUser() {}

    public static Observable<User> observe(final User user) {
        return Observable.create((emitter) -> {
              final User.ChangeListener changeListener = (user) -> {
                  emitter.onNext(user);
              }

              emitter.setDisposable(Disposables.fromAction(() -> { user.removeChangeListener(listener); }));

              user.addChangeListener(listener);
        });
    }

现在你可以做了

User u = new User();
Disposable disposable = RxUser.observe(u).subscribe((user) -> {
    // will be called for changes
});

u.setFirstName("hello");

Blackbelt 7 年前

一种方法是使用主题。你可以暴露潜在的 Observer Subject Subject.onNext ,所有订阅服务器都将收到更新的数据。

你可以阅读更多关于 Subject 在这里

推荐文章

somnathchakrabarti · 从Kotlin 2.0开始,启用Compose时需要Compose编译器Gradle插件

11 月前

Para1life · 解组时找不到类:com.google.firebase。时间戳,

11 月前

Murilo · Jetpack编写导航栏项目图标

11 月前

Santhosh Kumar · 当应用程序在Android 15 Pixel 9中重新启动时,Room DB被破坏

12 月前

KolaYAndr · 活动RESULT_OK似乎从未发生过

12 月前

Rashid Bilal · 主题更改时Android应用程序区域设置更改回英语

12 月前

Ruben P. Grady · 每种架构都有单独的构建,但生成的APK文件是相同的吗?

1 年前

psycho_pat · Android应用程序中的权限

1 年前

FarazFiroz · 如何将argb转换为描述性文本颜色

1 年前

Daniel · Unity Android游戏支持的设备数量太少

1 年前