PublishSubject和BehaviorSubject如何取消訂閱？

Question

根據subjects包你有類似PublishSubject和BehaviorSubject我想可以被描述爲一些可用的樣品Observables。

這些問題如何才能退訂？沒有unsubscribe方法，並呼籲onCompleted結束可觀測完全正確的？

Answer 1

一個主題是Observable和Observer在同一時間，它可以像正常觀測值一樣取消訂閱。使學科特別的是它是可觀察者和觀察者之間的橋樑。它可以通過重新發送它們來通過它觀察到的項目，並且它還可以發出新的項目。如果對未來承諾的話，對象應該是可觀察的。

這裏是主題系列的簡短描述：

AsyncSubject：只發射源可觀察

BehaviorSubject的最後一個值：發射最近發射的項目，所有的後續項目源觀察者訂閱它時可觀察

發佈主題：發出源Observable的所有後續項目在訂閱時

ReplaySubject：發出源Observable的所有項目，而不管訂戶何時訂閱。

的official doc提供了一些好的大理石圖這使得它更容易理解

Answer 2

主題基本上是都觀測量和觀察員。

可觀察到的基本上是有一個函數，觀察員和返回訂閱的事情。因此，例如，給出簡單的觀察到：

Observable<Integer> observable = Observable.create(new Observable.OnSubscribeFunc<Integer>() { 
     @Override 
     public Subscription onSubscribe(Observer<? super Integer> observer) { 
      observer.onNext(3); 
      observer.onNext(2); 
      observer.onNext(1); 
      observer.onCompleted(); 

      return Subscriptions.empty(); 
     } 
    }); 

在這裏，我們將訂閱它，打印出一條線的各整數：通過調用sub.unsubscribe()

Subscription sub = observable.subscribe(new Action1<Integer>() { 
     @Override 
     public void call(Integer integer) { 
      System.out.println(integer); 
     } 
    }); 

您將取消上述。

這裏是一個PublishSubject，做大致相同的事情：通過調用subscription.unsubscribe()

PublishSubject<Integer> publishSubject = PublishSubject.create(); 
    Subscription subscription = publishSubject.subscribe(new Action1<Integer>() { 
     @Override 
     public void call(Integer integer) { 
      System.out.println(integer); 
     } 
    }); 

    publishSubject.onNext(3); 
    publishSubject.onNext(2); 
    publishSubject.onNext(1); 

你會退訂用同樣的方式。

Answer 3

所有Subjects延長Observable您可以訂閱使用任何倍數subscribe(...)方法。呼籲任何subscribe(...)方法返回一個Subscription。

Subscription subscription = anySubject.subscribe(...); 

使用，當你想停止收聽來自受試者的事件，此subscription實例的unsubscribe()方法。

subscription.unsubscribe();