.subscribe()

在提供的引用中，有两种使用.subscribe()的方式。首先，引用中提到了在store对象中使用.subscribe()方法来订阅mutation的变化。这类似于Vuex中的subscribe方法。通过传入一个回调函数来订阅mutation的变化，并在每次mutation发生时执行该回调函数。示例代码如下：
const unsubscribe = store.subscribe((mutation, state) => {
console.log(mutation.type);
console.log(mutation.payload);
});
// 调用unsubscribe方法来停止订阅
unsubscribe();
引用和引用中提到了使用.subscribe()方法来订阅Observable对象中的事件。Observable对象是一种支持数据流的概念，可以通过create方法创建一个事件发射器，然后使用.subscribe()方法来订阅这个事件发射器。在引用中，没有传入任何参数给.subscribe()方法，这意味着事件发射器发出的事件将无人处理。而在引用中，传入了一个Consumer对象作为参数给.subscribe()方法，这个Consumer对象定义了对事件的处理逻辑。示例代码如下：
Observable.create(new ObservableOnSubscribe<Integer>() {
@Override
public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {
emitter.onNext(1);
emitter.onNext(2);
emitter.onNext(3);
emitter.onComplete();
emitter.onNext(4);
emitter.onNext(5);
Log.i("zqq","发送事件");
}
})
.subscribe(new Consumer<Integer>() {
@Override
public void accept(Integer integer) throws Exception {
Log.i("zqq","accept>>" + integer);
}
});
综上所述，.subscribe()方法可以用于订阅mutation的变化，也可以用于订阅Observable的事件。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* [$subscribe() 订阅状态及其变化](https://blog.csdn.net/gtLBTNq9mr3/article/details/126326340)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_2"}}] [.reference_item style="max-width: 50%"]
- *2* *3* [rxjava 三：subscribe() 的方法重载](https://blog.csdn.net/weixin_41648633/article/details/103859318)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_2"}}] [.reference_item style="max-width: 50%"]
[ .reference_list ]