RxSwiftとMVVM：観測なしバインディングなしで実行しない

Question

私はRxSwiftを初めて使い、MVVMアーキテクチャを使ってアプリケーションを実装しようとしています。私は、ビューモデルがあります：

class CategoriesViewModel { 

fileprivate let api: APIService 
fileprivate let database: DatabaseService 

let categories: Results<Category> 

// Input 
let actionRequest = PublishSubject<Void>() 

// Output 
let changeset: Observable<(AnyRealmCollection<Category>, RealmChangeset?)> 
let apiSuccess: Observable<Void> 
let apiFailure: Observable<Error> 

init(api: APIService, database: DatabaseService) { 
    self.api = api 
    self.database = database 

    categories = database.realm.objects(Category.self).sorted(byKeyPath: Category.KeyPath.name) 

    changeset = Observable.changeset(from: categories) 

    let requestResult = actionRequest 
     .flatMapLatest { [weak api] _ -> Observable<Event<[Category]>> in 
      guard let strongAPI = api else { 
       return Observable.empty() 
      } 

      let request = APIService.MappableRequest(Category.self, resource: .categories) 
      return strongAPI.mappedArrayObservable(from: request).materialize() 
     } 
     .shareReplayLatestWhileConnected() 

    apiSuccess = requestResult 
     .map { $0.element } 
     .filterNil() 
     .flatMapLatest { [weak database] newObjects -> Observable<Void> in 
      guard let strongDatabase = database else { 
       return Observable.empty() 
      } 

      return strongDatabase.updateObservable(with: newObjects) 
     } 

    apiFailure = requestResult 
     .map { $0.error } 
     .filterNil() 
} 

} 

を、私は、ビューコントローラで、次のbingindsあります

viewModel.apiSuccess 
     .map { _ in false } 
     .bind(to: refreshControl.rx.isRefreshing) 
     .disposed(by: disposeBag) 

    viewModel.apiFailure 
     .map { _ in false } 
     .bind(to: refreshControl.rx.isRefreshing) 
     .disposed(by: disposeBag) 

をしかし、私はバインディングコメント場合は、データベースの更新を持つ部分が実行を停止します。ビューモデルでdispose bagを使わずに、私はそれをとにかく実行させる必要があります。出来ますか？

そして、少し追加の質問：私は私のビューモデルのコードのようにapi/databaseとreturn Observable.empty()で弱い強いダンスを使うべきか、私は無事unowned api/unowned databaseを使用することができますか？

ありがとうございました。

UPD：APIServiceで観察復帰のための

機能：結果を受け取るために用意した加入者がある場合を除き

func mappedArrayObservable<T>(from request: MappableRequest<T>) -> Observable<[T]> { 
    let jsonArray = SessionManager.jsonArrayObservable(with: request.urlRequest, isSecured: request.isSecured) 
    return jsonArray.mapResponse(on: mappingSheduler, { Mapper<T>().mapArray(JSONArray: $0) }) 
} 

Answer 1

作業が行われません。

DatabaseServiceには、処分袋があり、Observable<[Category]>に登録する必要があります。何かのように：次に

class ProductionDatabase: DatabaseService { 

    var categoriesUpdated: Observable<Void> { return _categories } 

    func updateObservable(with categories: Observable<[Category]>) { 
     categories 
      .subscribe(onNext: { [weak self] categories in 
       // store categories an then 
       self?._categories.onNext() 
      }) 
      .disposed(by: bag) 
    } 

    private let _categories = PublishSubject<Void>() 
    private let bag = DisposeBag() 
} 

apiSuccess = database.categoriesUpdatedとdatabase.updateObservable(with: requestResult.map { $0.element }.filterNil())