在Android中用RxJava替换观察者模式

Question

我已经开始学习RxJava和RxAndroid。我想用RxJava替换我的观察者模式。observer模式类似于Android LocationManager类，该类具有register和unregister方法。“observable”类（不意味着rx.observable）在其自己的线程（HandlerThread）中工作，并拥有监听器及其处理程序对象的映射，每个监听器都在其线程中调用（通过处理程序）。我想这很清楚。所以问题是如何使用RxJava实现它？这有意义吗？我读过PublishSubject和Subscriber，但我不知道如何在其线程中运行我的Observable。我不想使用“subscribeOn”方法，因为订阅者不创建可观察的，而只订阅在自己的线程中接收通知。谢谢你的建议。

Answer 1

你的总体方法是好的。让我为你充实几个方面。

让我们假设您的可观察类负责一个随时间变化的值。之前，您需要注册一个观察者，当其值发生变化时，可观察对象会提醒每个观察者。假设您正在观察颜色变化。（警告：下面是未测试的代码。我使用了类似的代码将Observer模式调整到RxJava中。）

PublishSubject<Color> ps1 = new PublishSubject<>(); // your observable class
Observable<Color> observable = ps1.observeOn(Schedulers.newThread());
...
// handler in another thread
Subscription sub = observable.subscribeOn(myThreadScheduler).subscribe(myHandler);

现在，您的处理程序将在myThreadScheduler指定的线程上调用。您也可以通过sub.unsubscribe（）取消您的观察。