【Swift】RxSwift勉強してみたPart3

#はじめに
前回に引き続き、RxSwiftを勉強したので、その学習アウトプットです。
RxSwiftでHello World的なものを書いてみます。

#GitHub
以下のHelloRxSwiftフォルダに今回のプロジェクトはあります。

#実装
流れは以下の通りです。
1.HelloWorldSubjectというSubjectを定義
2.Subjectを購読
3.値が流れてきたらprintで値を出力されるように定義
4.定義したクラスが破棄されたら購読も自動的に破棄させる
5.N回イベントをながす
6.定義したクロージャがN回実行される

viewDidLoadでこのように書いてみます。

import UIKit
import RxSwift

class HelloRxViewController: UIViewController {
    
    private let disposeBag = DisposeBag()

    override func viewDidLoad() {
        super.viewDidLoad()
        
        let helloWorldSubject = PublishSubject<String>()
        helloWorldSubject.subscribe(onNext: { message in
            print("onNext: \(message)")
        }, onCompleted: {
            print("onCompleted")
        }, onDisposed: {
            print("onDisposed")
        })
        .disposed(by: disposeBag)
        
        helloWorldSubject.onNext("HelloWorld!")
        helloWorldSubject.onCompleted()

    }
}

出力結果

//onNext: HelloWorld!
//onCompleted
//onDisposed

このような書き方はViewControllerとViewModelや遷移元と遷移先のViewControllerのデータの受け渡しで使われます。
次はViewControllerとViewModelに分けて書いてみます。

HelloRxViewController

import UIKit
import RxSwift

class HelloRxViewController: UIViewController {
    
    private let disposeBag = DisposeBag()
    private let viewModel = HelloRxViewModel()
    
    override func viewDidLoad() {
        super.viewDidLoad()
        
        viewModel.helloWorldObservable
            .subscribe(onNext: { message in
                print("onNext: \(message)")
            }, onCompleted: {
                print("onCompleted")
            }, onDisposed: {
                print("onDisposed")
            })
            .disposed(by: disposeBag)
        
        viewModel.updateItem()
        
    }

}

HelloRxViewModel

class HelloRxViewModel {
    
    var helloWorldObservable: Observable<String> {
        return helloWorldSubject.asObservable()
    }
    private let helloWorldSubject = PublishSubject<String>()
    
    func updateItem() {
        helloWorldSubject.onNext("Hello World!")
        helloWorldSubject.onCompleted()
    }
    
}

出力結果

//onNext: HelloWorld!
//onCompleted
//onDisposed

#おわりに
RxSwiftまだまだわからないことだらけ、、、
次回