Rxswift オブザーバーのsubscribeについて

Question

オブザーバーのsubscribeについて質問があります。
一度だけsubscribeを行いたいのですが、現在subscribeしているかどうかを確認する方法はありますでしょうか。
現在は、下記ソースのようにフラグを使って制御しているのですが、確認する方法があるのであれば変更したいと思っています。

                if  firstlogout == true {
                    deviceRepository?.observableLogoutStatus?.subscribe({ event in

                        if event.element != nil && event.element! {
                            self.unbind(navigation: navigation)
                        }
                    }).disposed(by: disposeBag!)
                    firstlogout = false
                }

Answer 1

現在subscribeしているかどうかを確認する方法はありますでしょうか

これはないと思います。
というのも、 subscribeは定義のように書くべきで、初期化時などに一度だけ実行する想定がされているからだと思います。
言い換えると、同じオブジェクトの中で何度も同じ subscribe が実行する書き方は想定されてないものという意味です。

例えば ViewController で書くのであれば、

func viewDidLoad() { // ViewController なら viewDidLoad はライフサイクルで一度しか呼ばれない
  // ...

  // 例えば ViewController の初期化時に1度だけ実行するなら
  deviceRepository?.observableLogoutStatus?
    .subscribe({ event in /* ... */ })
    .disposed(by: disposeBag)

  // ボタンのタップによって実行するなら
  buttonView.rx.tap.asDriver()
    .flatMapLatest { _ in deviceRepository?.observableLogoutStatus }
    .drive { event in /* ... */ }
    .disposed(by: disposeBag)

  // その他イベント ( BehaviorRelay や PublishRelay等 ) によって実行する
  behaviorRelay
    .flatMapLatest { _ in deviceRepository?.observableLogoutStatus }
    .subscribe { event in /* ... */ }
    .disposed(by: disposeBag) 
} 

のように、イベントに対して flatMapLatest するように書けば、初期化時に1度だけ subscribe すればよいという風になります。
また、そのような書き方こそが宣言的で読みやすいコードとなるので、 RxSwift を利用するメリットになっているのかと思いますmm

Comments

[sportsgari]

勉強になりました。ありがとうございます。