RxSwiftで多次元配列をBehaviorSubjectに流したい

Question

前提・実現したいこと

Swift初学者です。Todoアプリを作成しており新規のtodoを作成で ObservableArray<Dictionary>に新しい辞書を追加できたのですがアプリを落とさず再度todoを追加するときに一つ前の辞書が消えてしまいます。値をBehaviorSubjectに流せば良いのかと考えたのですがRxにも慣れておらず良い方法が思いつかず困っています。

最終的に実現したいこととしては
アプリを落とすまではtoDosに辞書を追加し続け値に変更があるたびに表示するVCに配列を流せるようにしたいです。

該当のコード

全てView.Modelのコードです。

import RxSwift
import RxCocoa
import ObservableArray_RxSwift

final class CreateListViewModel {
    
    let bag = DisposeBag()
/// 中間Stream for Input
    //PublishSubject：外からの入力のみを受け付ける
    private let createBtnDidTapStream = PublishSubject<Void>()
    private let genreStream = BehaviorSubject<String>(value: "")
    private let toDoStream = BehaviorSubject<String>(value: "")
/// 中間Stream for Output
    private let navigateToMainStream = PublishSubject<Void>()

  //仮説：ほんとはここに値を流して最新のものをあとで参照すれば良いのか
  //private let toDoListStream = BehaviorSubject<[[String : Any]]>( value: [[:]])
    
    init() {
        self.createBtnDidTapStream
            .subscribe(onNext: {[weak self] _ in
                self?.createList()
            })
            .disposed(by: bag)
        
        self.genreStream
            .subscribe(onNext: { [weak self] genre in
                print(genre)
            })
            .disposed(by: bag)
        self.toDoStream
            .subscribe(onNext: { [weak self] toDo in
                print(toDo)
            })
            .disposed(by: bag)
    }
    
   
    var toDos: ObservableArray<Dictionary> =
        [["toDo":"test", "hasDone": false, "genre": "test" ]]
    
    func createList() {
        //オンメモリでデータの一時保存。。これは保存というより代入
        //データ保存の永続化は今回はなし
  
        toDos.append([
            "toDo": try! toDoStream.value(),
            "genre": try! genreStream.value(),
            "hasDone": false
            ])
        print(toDos)
        //main画面へ遷移
        self.navigateToMainStream.onNext(())
        
        
        }


    
        func editStatus() {
            
        }
    
}
///input
extension CreateListViewModel {
    //投稿ボタン
    var createBtnDidTap: AnyObserver<()> {
        return createBtnDidTapStream.asObserver()
    }
    //ジャンルテキストフィールド
    var genre: AnyObserver<String> {
        return genreStream.asObserver()
    }
    var toDo: AnyObserver<String> {
        return toDoStream.asObserver()
    }
    

}


///output
extension CreateListViewModel {
    var navigateToMain: Observable<Void> {
        return self.navigateToMainStream.asObservable()
    }
//    var toDoList: ObservableArray<[String: Any]> {
//        return self.toDoStream.asObservable()
//    }
    
}

試したこと

return self.toDoStream.asObservable()でどうにか値を流せないか四苦八苦してました。

補足情報（FW/ツールのバージョンなど）

XCode 9.4.1
Swift 4.1.2
pod 1.5.3

配列をObservableにするためObservableArray_RxSwiftというライブラリを使っています。

Answer 1

ObservableArray_RxSwift のREADMEを読む限りだと、使い方が違っているようですね。 rx_elements() メソッドにより提供されるストリームが合成後の配列を流してくれるものですから、そちらを見るようにしてみてください。

---

ここからは余談で、実装方針についてのアドバイスです。

ご質問の今のコードだと、RxSwiftがただの通知用ライブラリとして使われている感じでちょっともったいないです。せっかくRxSwiftを使っているのですから、もうちょっとリアクティブな実装にしてみましょう。

Rxでは、入力となるストリームを元にして出力となるストリームを組み立てていくことで処理を実装します。
今回の場合は、入力となるストリーム

• createBtnDidTapStream
• genreStream
• toDoStream

の3つを元に出力 toDoListStream を組み立てることを考えてみます。

まず、値を追加する契機となるイベントはボタンのタップですから、 createBtnDidTapStreamがベースとなります。そこにgenreStream, toDoStreamの最新の値を加えてDictionaryを流すストリームは、以下のように実装できます。

self.toDoListStream = self.createBtnDidTapStream
    .withLatestFrom(Observable.combineLatest(
        self.toDoStream.asObservable(),
        self.genreStream.asObservable()
    )) { _, todoAndGenre -> [String: Any] in
        let (todo, genre) = todoAndGenre
        return [ "toDo": todo, "genre": genre, "hasDone": false ]
    }

さらに、イベントが流れるたびに値を配列に追加していく処理は、scan オペレーターで実装できます。scanはreduceオペレーターと似ていますが、イベントが流れるたびに結果を流す点で異なります。（詳しくは調べてみてください）

self.toDoListStream = self.createBtnDidTapStream
    .withLatestFrom(Observable.combineLatest(
        self.toDoStream.asObservable(),
        self.genreStream.asObservable()
    )) { _, todoAndGenre -> [String: Any] in
        let (todo, genre) = todoAndGenre
        return [ "toDo": todo, "genre": genre, "hasDone": false ]
    }
    .scan([]) { todoList, dict in
        return todoList + [dict]
    }

これで、 ボタンがタップされるたびにTODOを配列に追加してその結果を流すストリーム の完成です。この方法なら、ObservableArray-RxSwiftを使う必要もありません。

あとはこれを外部に公開してVC側でsubscribeするなりしてみてください。

Comments

[oyasumi]

kakajikaさん丁寧な回答ありがとうございます！実装方針についてかなり参考になったのですが
toDoListStreamを多次元配列もしくはArrayで持つとどうしてもエラーを吐かれてしまいビルドできません。どういう風にtoDoListStreamを置くことを想定されていたか教えていただけないでしょうか？よろしくお願いいたします。

[kakajika]

toDoListStreamの型が何かということでしょうか？
let toDoListStream: Observable<[[String: Any]]>
です

[oyasumi]

度々申し訳ないです。
Cannot assign to property: 'toDoListStream' is a 'let' constant　Change 'let' to 'var' to make it mutableと出てしまいletで定義できなかったので一旦fixしました。立て続けにCannot assign value of type 'Observable<[String : Any?]>' to type 'Observable<[[String : Any]]>'というエラーになってしまったので
todoAndGenre -> [String: Any?]でAnyがOptionalなのを変更してみました。
それとは別で
init()のところでVariable 'self.toDoListStream' used before being initializedというエラーも起きました。
ボタンのタップを元にtoDoListStreamを生成するということはわかりやすかったのですが
なぜvmをイニシャライズするところで怒られるのかが分かりませんでした。
分かりづらい文章ですみません。もう少々お付き合いください。。m(__)m

[kakajika]

まだSwiftは書きなれてない感じですかね？ letで宣言したプロパティは、initの中で初期化してあげないと怒られます。また、init後に書き換えることはできません。

一応、gistにコード例を置いておきました。ビルド・動作確認はしてません。
https://gist.github.com/kakajika/1cb14658237808a570bd01c6cd60150e

[String: Any?] については、すみません。ちょっと前に回答を編集したのですが、編集前のコードだとOptionalになっていました。最新の回答をご覧ください。

[oyasumi]

コードまでありがとうございます！描き慣れておらず基本的なところも抜け漏れていました。
おかげさまでかなり勉強になりました。丁寧にありがとうございました。