RxSwift subscribeの内部でsubscribeを終了させたい

Question

RxSwiftを使用しているのですが、subscribe処理の中で購読を終了させたいと思っています。購読を停止するためにはSubscribeの戻り値をDisposeすれば良いみたいですが、戻り値をSubscribeの内部で使用する方法はありますでしょうか。ご教示願います。

他のsubscribeに影響を与えないように、下記subscribeのみdisposeしたいと考えております。

deviceRepository?.observableDisconnectToDeviceStatus?.subscribe({ event in
                    if event.element != nil && event.element! {
                        self.unbind(navigation: navigation)
                    }
                }).disposed(by: disposeBag!)

Answer 1

Rxのストリームはcompletedの状態になれば自動的にdisposeされます。これを利用して、目的の条件を満たすイベントが1度流れたらcompletedにするようにストリームを組むのがRx的には自然なやり方かなと思います。

deviceRepository?.observableDisconnectToDeviceStatus?
    .filter { event in event.element != nil && event.element! }
    .first() // 最初のイベントだけ流してcompleteする
    .subscribe { [weak self] in self?.unbind(navigation: navigation) }
    .disposed(by: disposeBag)

Comments

[sportsgari]

ご回答いただき誠にありがとうございます。
説明不足で申し訳ありませんが、他のsubscribeは終了させずに一つだけ終了させたいと考えています。

[kakajika]

他のsubscribeというのは何でしょうか？回答した方法でdisposeされるのは対象の購読のみです。

[sportsgari]

申し訳ありません。理解不足でした。ご回答いただきありがとうございます。