Блог

Я хочу получить данные с сервера и обновить свою базу данных, после чего я покажу полученные данные пользователю. Для этой цели у меня есть метод ( getData() ) в моей модели представления, который возвращает Single Я вызываю и подписываюсь на этот метод в контроллере представления ( myVC.getData.subscribe({single in ...}) ) в этом методе сначала я вызываю и подписываюсь (# 1) ( getUnread()->Single ) метод выполняется, но я не могу получить единственное событие, я не могу понять, почему я не могу получить событие (# 3) в обратном вызове (# 4)

после этого я хочу сохранить данные с помощью вызова (# 2) (save([Moddel])-> single)

 //I removed some part of this code it was to big
//This method is View Model
func getData() -> Single<[Model]> {
    return Single<[Model]>.create {[weak self] single in
        //#1
        self!.restRepo.getUnread().subscribe({ [weak self] event in
            //#4
            switch event {
            case .success(let response):
                let models = response
                //#2
                self!.dbRepo.save(issues!).subscribe({ event in
                    switch event {
                    case .success(let response):
                        let models = response
                        single(.success(models))
                    case .error(let error):
                        single(.error(error))
                    }
                }).disposed(by: self!.disposeBag)
            case .error(let error):
                single(.error(error))
            }
        }).disposed(by: self!.disposeBag)
        return Disposables.create()
    }
}
  

.
.

  //I removed some part of this code it was to big
 //This method is in RestRepo class
 func getUnread() -> Single<[Model]> {
    
    return Single<[Model]>.create { single in
        let urlComponent = ApiHelper.instance.dolphinURLComponents(for: ApiHelper.ISSUES_PATH)
        var urlRequest = URLRequest(url: urlComponent.url!)

        ApiHelper.instance.alamofire.request(urlRequest).intercept().responseJSON { response in
            debugPrint(response)
            let statusCode = response.response?.statusCode
            switch statusCode {
            case 200:
                do {
                    let models = try JSONDecoder().decode([Model].self, from: response.data!)
                    //#3
                    single(.success(models))
                }catch{
                    print(error)
                }
            case 304:
                debugPrint(response)
            default:
                single(.error(IssueResponseStatusCodeError(code: statusCode ?? 0)))
            }
        }
    return Disposables.create()
    }
  

Сначала вам нужно изменить свое мышление. Вы ничего не делаете в приложении. В лучшем случае вы размещаете наблюдаемые цепочки (которые не делают ничего больше, чем водопроводные трубы «делают» что-то.) Затем вы запускаете приложение и позволяете «воде» течь.

Итак, имея это в виду, давайте рассмотрим ваш вопрос:

Я хочу получить данные с сервера…

Дело не в том, что «вы» хотите получить данные. Запрос сделан в результате некоторого действия (возможно, нажатия кнопки) пользователя или какого-либо другого побочного эффекта. Что это за действие? Это должно быть выражено в коде. Для следующего я предположу, что это нажатие кнопки. Это означает, что у вас должно быть:

 class Example: UIViewController {
    var button: UIButton!
    var restRepo: RestRepo!

    override func viewDidLoad() {
        super.viewDidLoad()
        let serverResponse = button.rx.tap
            .flatMapLatest { [restRepo] in
                restRepo!.getUnread()
                    .map { Result<[Model], Error>.success($0) }
                    .catchError { .just(Result<[Model], Error>.failure($0)) }
            }
            .share(replay: 1)
    }
}

protocol RestRepo {
    func getUnread() -> Observable<[Model]>
}

struct ProductionRestRepo: RestRepo {
    func getUnread() -> Observable<[Model]> {
        let urlComponent = ApiHelper.instance.dolphinURLComponents(for: ApiHelper.ISSUES_PATH)
        let urlRequest = URLRequest(url: urlComponent.url!)
        return URLSession.shared.rx.data(request: urlRequest)
            .map { try JSONDecoder().decode([Model].self, from: $0) }
    }
}

class ApiHelper {
    static let ISSUES_PATH = ""
    static let instance = ApiHelper()

    func dolphinURLComponents(for: String) -> URLComponents { fatalError() }
}

struct Model: Decodable { }

  

Здесь следует обратить внимание на то, что getUnread() это эффект, который вызван button.rx.tap . Вышесказанное устанавливает причинно-следственную цепочку.

Далее в вашем вопросе говорится, что «вы» хотите:

… обновите мою базу данных…

Здесь причиной является сетевой запрос, а следствием является сохранение в базе данных, поэтому нам просто нужно добавить это в viewDidLoad (обратите внимание, что приведенный ниже код использует RxEnumKit.):

 let dbResponse = serverResponse
    .capture(case: Result.success)
    .flatMapLatest { [dbRepo] models in
        dbRepo!.save(models)
            .map { Result<Void, Error>.success(()) }
            .catchError { .just(Result<Void, Error>.failure($0)) }
    }
  

В вашем вопросе также говорится, что «вы» хотите:

… показать полученные данные пользователю.

Обратите внимание, что отображение полученных данных пользователю не имеет ничего общего с сохранением в базе данных. Это две независимые операции, которые могут выполняться параллельно.

Показ полученных данных пользователю имеет ServerResponse в качестве причины, а отображение — в качестве эффекта.

 serverResponse
    .capture(case: Result.success)
    .subscribe(onNext: { models in
        print("display the data to the user.", models)
    })
    .disposed(by: disposeBag)
  

Наконец, вы не упоминаете об этом, но вам также приходится обрабатывать ошибки:

Так что добавьте это также в viewDidLoad:

 Observable.merge(serverResponse.capture(case: Result.failure), dbResponse.capture(case: Result.failure))
    .subscribe(onNext: { error in
        print("an error occured:", error)
    })
    .disposed(by: disposeBag)
  

Приведенный ниже код представляет собой все вышеперечисленное в виде единого блока. Это отлично компилируется…

 import UIKit
import RxSwift
import RxCocoa
import EnumKit
import RxEnumKit

extension Result: CaseAccessible { }

class Example: UIViewController {
    var button: UIButton!
    var restRepo: RestRepo!
    var dbRepo: DBRepo!
    let disposeBag = DisposeBag()

    override func viewDidLoad() {
        super.viewDidLoad()
        let serverResponse = button.rx.tap
            .flatMapLatest { [restRepo] in
                restRepo!.getUnread()
                    .map { Result<[Model], Error>.success($0) }
                    .catchError { .just(Result<[Model], Error>.failure($0)) }
            }
            .share(replay: 1)

        let dbResponse = serverResponse
            .capture(case: Result.success)
            .flatMapLatest { [dbRepo] models in
                dbRepo!.save(models)
                    .map { Result<Void, Error>.success(()) }
                    .catchError { .just(Result<Void, Error>.failure($0)) }
            }

        serverResponse
            .capture(case: Result.success)
            .subscribe(onNext: { models in
                print("display the data to the user.", models)
            })
            .disposed(by: disposeBag)

        Observable.merge(serverResponse.capture(case: Result.failure), dbResponse.capture(case: Result.failure))
            .subscribe(onNext: { error in
                print("an error occured:", error)
            })
            .disposed(by: disposeBag)
    }
}

protocol RestRepo {
    func getUnread() -> Observable<[Model]>
}

protocol DBRepo {
    func save(_ models: [Model]) -> Observable<Void>
}

struct ProductionRestRepo: RestRepo {
    func getUnread() -> Observable<[Model]> {
        let urlComponent = ApiHelper.instance.dolphinURLComponents(for: ApiHelper.ISSUES_PATH)
        let urlRequest = URLRequest(url: urlComponent.url!)
        return URLSession.shared.rx.data(request: urlRequest)
            .map { try JSONDecoder().decode([Model].self, from: $0) }
    }
}

class ApiHelper {
    static let ISSUES_PATH = ""
    static let instance = ApiHelper()

    func dolphinURLComponents(for: String) -> URLComponents { fatalError() }
}

struct Model: Decodable { }
  

Я надеюсь, что все это поможет вам или, по крайней мере, вызовет больше вопросов.