0

我有一个应用程序，我正在尝试使用 MVVM 实现 RxSwift。

我有 SignInViewModel ，我在其中进行验证，并且正在使用我正在收听的其余响应布尔值更新可观察的登录。

在控制器类中，只要验证通过，登录按钮就会启用。

以类似的方式，我希望能够在单击按钮时启动微调器，并在用户收到响应时关闭。

当我尝试从控制器类中的视图模型中收听 loginObservable 时。它没有命中绑定块。

我无法弄清楚问题所在。

任何帮助将不胜感激

以下是我的 SignInViewModel

class SignInViewModel {

    let validatedEmail: Observable<Bool>
    let validatedPassword: Observable<Bool>
    let loginEnabled: Observable<Bool>
    let loginObservable: Observable<Bool>

    init(username: Observable<String>,
         password: Observable<String>,
         loginTap: Observable<Void>) {

        self.validatedEmail = username
            .map { $0.characters.count >= 5 }
            .shareReplay(1)

        self.validatedPassword = password
            .map { $0.characters.count >= 2 }
            .shareReplay(1)

        self.loginEnabled = Observable.combineLatest(validatedEmail, validatedPassword ) { $0 && $1 }
        let userAndPassword = Observable.combineLatest(username, password) {($0,$1)}

        self.loginObservable = loginTap.withLatestFrom(userAndPassword).flatMapLatest{ (username, password) in
            return RestService.login(username: username, password: password).observeOn(MainScheduler.instance)
        }
    }
}

以下是 moyaRequest 类

final class MoyaRequest{
    func signIn(userData: Creator) -> Observable<Response> {
            return provider.request(.signIn(userData))
                .filter(statusCode: 200)
        }
}

以下是我的 RestService 课程

class RestService:NSObject {

    static var moyaRequest = MoyaRequest()
    static var disposeBag = DisposeBag()

static func login(username: String, password: String) -> Observable<Bool> {
    let userData = Creator()
    userData?.username = username
    userData?.password = password
    print("Username password", userData?.username, userData?.password)
    return  Observable.create { observer in moyaRequest.signIn(userData: userData!).subscribe{ event -> Void in
        switch event {

        case .next(let response):
            print("Response",response)

        case .error(let error):
            let moyaError: MoyaError? = error as? MoyaError
            let response: Response? = moyaError?.response
            let statusCode: Int? = response?.statusCode

            print("Sample Response code error" + String(describing: statusCode))
        default:
            break
        }
        }
        return Disposables.create()
    }

}

}

我正在尝试在控制器类中绑定视图模型。

class SignInViewController: UIViewController{

    let disposeBag = DisposeBag()
    @IBOutlet weak var passwordTextfield: UITextField!
    @IBOutlet weak var usernameTextfield: UITextField!

    private var viewModel : SignInViewModel!
    @IBOutlet weak var signInButton: UIButton!
    override func viewDidLoad() {
        setUpRxViewModel()

    }

    func setUpRxViewModel(){
        self.viewModel = SignInViewModel(username: self.usernameTextfield.rx.text.orEmpty.asObservable(),
                                         password: self.passwordTextfield.rx.text.orEmpty.asObservable(),
                                         loginTap: self.signInButton.rx.tap.asObservable())

        self.viewModel.loginEnabled.bind{ valid  in
            self.signInButton.isEnabled = valid
            }.addDisposableTo(disposeBag)

        self.viewModel.loginObservable.bind{ input in
            print("Login Clicked")
            }.addDisposableTo(disposeBag)


    }
}
4

1 回答 1

1

在您的login方法中，您没有向观察者发送任何事件。它应该是：

case .next(let response):
            observer.on(.next(true))
            print("Response",response)

case .error(let error):
            observer.on(.error(error))
            //or observer.on(.next(false)) if you intend to use Bool as indicator of operation success which is a very bad idea.
            let moyaError: MoyaError? = error as? MoyaError
            let response: Response? = moyaError?.response
            let statusCode: Int? = response?.statusCode

RxMoyaProvider此外，如果您将 Moya 与 RxSwift 一起使用，我建议您在任何地方使用。使用Observable.create通常意味着你做错了什么。

您也不应该在网络请求级别根据状态代码过滤事件，因为如果出现问题，您将不会收到链中的任何事件。

于 2017-11-03T17:17:39.297 回答