处理重复的订阅回调，线程切换时，不再重复注册。

ldw5821cn · Jan 6, 2020 · 50791a2 · 50791a2
1 parent 0ad72f8
commit 50791a2
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/main/java/io/github/ldw5821cn/observer/ObservableObserveOn.java b/src/main/java/io/github/ldw5821cn/observer/ObservableObserveOn.java
@@ -17,7 +17,6 @@ public ObservableObserveOn(ObservableSource<T> source, Scheduler scheduler) {
  @Override
  protected void subscribeActual(Observer<T> observer) {
  ObserverOnObserver observeOn = new ObserverOnObserver(observer);
- observer.onSubscribe();
  source.subscribe(observeOn);
  scheduler.scheduleDirect(observeOn);
  }
@@ -57,6 +56,9 @@ public void onError(Throwable t) {
 
  @Override
  public void onSubscribe() {
+ if(!isSubscribed.compareAndSet(false,true)){
+ return;
+ }
  actual.onSubscribe();
  }