我是 RxSwift 的初学者，我想从一个简单的登录屏幕开始。所以我有 2 个文本字段和一个登录按钮，它绑定(bind)到 PublishSubject 所以每次我点击按钮时，我都会发送一个网络请求来执行身份验证。

由于身份验证可能会失败，我使用了一个驱动程序，这样我就可以在每次单击按钮时重播我的请求。

我有 2 个版本的代码，我认为是相同的代码，但一个有效，一个无效。 我试图了解幕后发生的事情。

这是第一个有效的版本(每次我触摸按钮时请求):

let credentials = Driver.combineLatest(email.asDriver(), password.asDriver()) { ($0, $1) }
self.signIn = signInTaps
    .asDriver(onErrorJustReturn: ())
    .withLatestFrom(credentials)
    .flatMapLatest { email, password in // returns Driver<Result<AuthenticateResponse, APIError>>
        return provider.request(.Authenticate(email: email, password: password))
            .filterSuccessfulStatusCodes()
            .mapObject(AuthenticateResponse)
            .map { element -> Result<AuthenticateResponse, APIError> in
                return .Success(element)
            }
            .asDriver { error in
                let e = APIError.fromError(error)
                return Driver<Result<AuthenticateResponse, APIError>>.just(.Failure(e))
            }
            .debug()
    }

这是一个不起作用的(请求仅在第一次点击时触发):

let credentials = Observable.combineLatest(email.asObservable(), password.asObservable()) { ($0, $1) }
self.signIn = signInTaps.asObservable()
    .withLatestFrom(c)
    .flatMapLatest { email, password in // returns Observable<AuthenticateResponse>
        return provider.request(.Authenticate(email: email, password: password))
            .filterSuccessfulStatusCodes()
            .mapObject(AuthenticateResponse)
    }
    .map { element -> Result<AuthenticateResponse, APIError> in // returns Observable<Result<AuthenticateResponse, APIError>>
        return .Success(element)
    }
    .asDriver { error in // returns Driver<Result<AuthenticateResponse, APIError>>
        let e = APIError.fromError(error)
        return Driver<Result<AuthenticateResponse, APIError>>.just(.Failure(e))
    }
    .debug()

有关信息，这是我的属性声明:

let email = Variable("")
let password = Variable("")
let signInTaps = PublishSubject<Void>()    
let signIn: Driver<Result<AuthenticateResponse, APIError>>

最佳答案

让我们分解一下第一个中发生的事情(因为它们大部分相同):

// 1.
let credentials = Driver.combineLatest(email.asDriver(), password.asDriver()) { ($0, $1) }
// 2.
self.signIn = signInTaps
    .asDriver(onErrorJustReturn: ())
    // 3.
    .withLatestFrom(credentials)
    // 4.
    .flatMapLatest { email, password in // returns Driver<Result<AuthenticateResponse, APIError>>
    return provider.request(.Authenticate(email: email, password: password))
        .filterSuccessfulStatusCodes()
        .mapObject(AuthenticateResponse)
        .map { element -> Result<AuthenticateResponse, APIError> in
            return .Success(element)
        }
        .asDriver { error in
            let e = APIError.fromError(error)
            return Driver<Result<AuthenticateResponse, APIError>>.just(.Failure(e))
        }
        .debug()
}

1. 您正在组合来自 email 和 password 的最新信号，并将它们组合成一个 String 元组。
2. 这是您的登录信号，是以下所有信号的组合。
3. 您只需轻按一下按钮即可将来自 credentials 的最新结果组合起来。
4. 每次点击按钮或发出电子邮件/密码时，您都会取消当前信号并创建一个新信号来进行调用(使用 Moya)、按成功状态代码进行过滤、映射对象并处理成功和错误。

除了您使用的是可观察对象而不是驱动程序之外，第二个示例基本相同。检查 signInTaps 并查看您是否在每次点击按钮时都收到事件。可能是在线下某处信号正在释放，实际上这两个版本之间的唯一区别是驱动程序和可观察对象的使用。

另请记住，使用驱动程序只是可观察对象的语法糖。

let intDriver = sequenceOf(1, 2, 3, 4, 5, 6)
.asDriver(onErrorJustReturn: 1)
.map { $0 + 1 }
.filter { $0 < 5 }

与

let intObservable = sequenceOf(1, 2, 3, 4, 5, 6)
.observeOn(MainScheduler.sharedInstance)
.catchErrorJustReturn(1)
.map { $0 + 1 }
.filter { $0 < 5 }
.shareReplay(1)

因此，当您在驱动程序上使用可观察对象时，您将失去 .observeOn 和 shareReplay。可能是因为对于驱动程序，您只能看到重播和缓存的值。

关于ios - RxSwift - 误解了一些概念，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/36990570/