観測対象から退会するにはどうしたらいいですか？

Question

私はこのようなものがある場合：私はbarの後半で観測可能でunsubscribeにしたい場合は、

func foo() -> Observable<Foo> { 
    return Observable.create { observer in 
     // ... 
    } 
    } 

    func bar() { 
    foo().observeOn(MainScheduler.instance) 
     .subscribeNext { 
     // ... 
     } 
     .addDisposableTo(disposeBag) 
    } 

を、私はそれをどのように行うのでしょうか？

更新

私はdisposeを呼び出すことができます承知だけど、RxSwift docsに応じて：あなたは、通常は手動で処分を呼び出すにしたくない

注意。これは教育的な例にすぎません。手動で処理を呼び出すのは、通常、コードの悪臭です。

unsubscribeは実装されていませんか？私はRxSwiftコードを使って動くようになりました。何が起こっているのかを理解することができる程度に、サブスクライブメソッドから返されたDisposableは有用な機能（ディスポーザリング以外のもの）を持つものではありません。

Answer 1

fooからdisposeBagで返されたObservableを追加します。割り当てが解除されると、サブスクリプションが破棄されます。 あなたは "手動" あなたのクラスのどこかに

disposeBag = nil

を呼び出すことによってdisposeBagを解放することができます。

質問の編集後：おそらくいくつかの条件が満たされたときにObservableから一部の受信者を選択的に退会させたいとします。これらの条件を表す別のObservableを使用して、takeUntil演算子を使用して必要に応じてサブスクリプションを取り消すことができます。私はあなたが処分したいときに解放したいときにあなただけのtempBag = nilを行うことができます別のDisposeBag

var tempBag = DisposeBag() 

fun bar() { 
    foo().subscribe().addDisposable(tempBag) 
} 

を作成していた何をしたか

//given that cancellingObservable sends `next` value when the subscription to `foo` is no longer needed 

foo().observeOn(MainScheduler.instance) 
    .takeUntil(cancellingObservable) 
    .subscribeNext { 
    // ... 
    } 
    .addDisposableTo(disposeBag) 

Answer 2

。あなたはまだ他の使い捨て物を生き続ける別のDisposeBagを持っています。