在触发器可观察对象上对某些可观察对象执行操作 - RxJS

Question

我仍在尝试使用 RxJS 和 React Native。我正在构建一个带有 id TextInput、密码 TextInput 和登录按钮的登录屏幕，它们都通过 jsx 附加了一个单独的回调处理程序（因此我无法使用 RxJS 的“fromEvent”API 创建可观察对象）。

在 componentWillMount 中，我为 id 文本更改、密码文本更改和单击处理程序创建了一个主题。

//In id text change handler
this.idStream.onNext(newId);

//In password text change handler
this.passwordStream.onNext(newPassword);

//In click handler
this.buttonClickStream.onNext(null); //null since value is not important

我只希望在按钮 ID 和密码不是空字符串并且单击按钮时触发 API 请求。

在componentWillMount我试过

var subscription = this.buttonClickStream
                       .combineLatest(this.idStream, this.passwordStream, function(click, id, password) {
    return {
         id: id,
         password: password
    };
})
.filter(credentials => {return credentials.id.length > 0 &&
                               credentials.password.length > 0;}
.subscribe(function(credentials) {
    console.log('fire API request with credentials');
});

但是问题在于，由于我使用的是 combineLatest，因此不仅在单击按钮时触发 api，而且每次更改 id 或密码时都会触发 api（前提是它们通过了过滤器）。我错过了什么？

谢谢！

Answer 1

我认为您可以使用Rx.withLatestFrom 代替combineLatest。它仅在源 observable 触发并将您传递的 observable 最后发出的值作为参数时触发。

参照。 http://rxmarbles.com/#withLatestFrom