- Java 双重比较
- java - 比较器与 Apache BeanComparator
- Objective-C 完成 block 导致额外的方法调用?
- database - RESTful URI 是否应该公开数据库主键?
我正在尝试创建一种方法来返回可以存储在三个位置之一的设置。我创建了三个可观察对象,每个都尝试从源中检索设置值。我希望能够以创建 IF/ELSE IF/ELSE 构造的方式“加入”这些,以便最后只有一个 Observables 发出设置值。从一个 observable 转移到下一个 observable 的条件是前一个“失败”,即发出了一个没有通过条件的值。尝试每个选项的顺序很重要。
到目前为止,我的方法看起来像这样:
getSetting(settingName: string): Observable<any> {
const optionOne$ = this.getItemAtFirst(settingName).pipe(
take(1),
filter(setting => setting && this.isSettingValid(settingName, setting)));
const optionTwo$ = this.getItemAtSecond().pipe(
take(1),
filter(setting => setting && this.isSettingValid(settingName, setting)));
const optionThree$ = of(this.defaultSettingValue);
return merge(optionOne$, optionTwo$, optionThree$);
}
这显然行不通,因为 merge
没有提供我需要的选择效果。
有什么建议吗?提前致谢!
最佳答案
编辑:TL;DR
将 merge
替换为 concat
并将 first
添加到您的 concat
上的管道中:
concat(optionOne$, optionTwo$, optionThree$)
.pipe(
first()
);
concat
按顺序订阅每个 observable,这意味着 optionOne$
首先被订阅,它发出它的值,当它完成时它被取消订阅,然后 concat
订阅 optionTwo$
,依此类推...直到所有可观察对象完成,然后最终将所有值作为数组发出。添加 first
只是缩短了这个过程,因为它在发出第一个值后完成了连接。
您确实需要检查 concat
中的所有可观察对象是否会完成,否则您可能会遇到其中一个永远不会发出或完成的情况,这意味着您永远不会得到从 concat
发出的值。
———
假设您的 isSettingValid()
在验证失败时返回 false,那么只需添加一个带有 first()
的 pipe()
到连接()
。请参阅下面稍作修改的版本,以及 stackblitz在这里。
这article也是翔实的。我建议这个 article它有很酷的 gif 来解释运算符和它们是如何工作的——当我试图弄清楚这样的事情时,我总是会回到它。
我认为这回答了您的问题,因为它发出第一个通过验证的值并忽略其余值。
import { of, Observable, concat } from 'rxjs';
import { take, filter, first } from 'rxjs/operators';
function isSettingValid(setting): boolean {
return setting !== 'error' ? true : false;
}
function getSetting(): Observable<any> {
const optionOne$ = of('error')
.pipe(
take(1),
filter(setting => isSettingValid(setting))
);
const optionTwo$ = of('second')
.pipe(
take(1),
filter(setting => isSettingValid(setting))
);
const optionThree$ = of('default').pipe(
take(1),
filter(setting => isSettingValid(setting))
);
return concat(optionOne$, optionTwo$, optionThree$)
.pipe(
first() // emits only the first value which passes validation then completes
);
}
getSetting()
.subscribe((setting) => {
console.log(setting);
})
我还建议删除 setting &&
,就像在我的代码片段中一样,并将 null 检查放在验证函数中 - 如果您这样做,它只会使过滤器更易于阅读 imo。为了使其更简洁,您可以考虑将 take(1)
和 filter()
替换为 first
和一个具有相同功能的谓词函数结果:
const optionOne$ = of('error')
.pipe(
first(setting => isSettingValid(setting))
);
关于angular - IF/ELSE IF/ELSE 以 Observable 作为条件,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/54571544/
一段时间后,我阅读了有关 RxJava concat 的内容,并决定测试一下我的理解力。但是我遇到了一些我不太理解的行为。 问题是,当我连接两个可观察对象时,根据我将它们传递给 Observable.
我正在使用来自数据库服务的数据实现自动完成: @Injectable() export class SchoolService { constructor(private db: AngularF
我正在尝试使用 RxJS 创建一个可观察的对象,它可以执行如图所示的操作。 获取一个值并等待一段固定的时间才能获得 下一个。 下一个将是该周期内发出的最后一个值 等等,跳过其余部分。 如果等待时间间隔
我有一个可观察对象和另一个提供的可观察对象改变 key 。我想构建一个在之间切换的可观察对象基于该键的对象中的可观察值。 示例: // Choose randomly between "up" or
我使用 protobuffers 在我的前端和我的 Dart 服务器之间进行通信。 那些对象没有实现 Observable . 我的 Dart 聚合物对象看起来像: @CustomTag('user-
在 java swing 项目中,我有一个模型类,它保存某个 JPanel 的状态。我需要使这些数据可供 View 使用。我认为有两种选择。有一个扩展 Observable 的类并将模型作为实例变量。
我想找到一种方法来检测观察者是否已完成使用我使用 Rx.Observable.create 创建的自定义可观察对象,以便自定义可观察对象可以结束它并正确地进行一些清理。 因此,我创建了一些测试代码,如
我正在尝试查询数据库。迭代结果列表,并为每一项再执行一个请求。在 rxjs 构建结束时,我有 Observable[]> 。但我需要Observable 。如何做到这一点? this.caseServ
我希望我的 api 上有一个方法返回 Observable> 但我希望该方法中的代码知道所有包含的 Observables 是否已完成,以便它可以关闭某些内容。最好的方法是什么? 更明确地说,我希望完
我有两个方法返回 Observable> firstAPI.getFirstInfo("1", "2"); secondApi.getSecondInfo(resultFirstObservable,
我有一个 Observable返回单个 Cursor实例(Observable)。我正在尝试利用 ContentObservable.fromCursor获取 onNext 中每个游标的行回调。 我想
我有两种返回 Observable 的方法: Observable firstObservable(); Observable secondObservable(String value); 对于第一
我正在尝试创建一个将用户数据作为 Observable 的函数,并使用来自第一个 observable 的数据从查询中添加/合并数据,然后将所有这些数据作为一个 observable 返回,我可以这样
我有一个 spec-compliant ECMAScript Observable ,具体来自 wonka library .我正在尝试将这种类型的 observable 转换为 rxjs 6 obs
为了简化问题,我在这里使用了数字和字符串。代码: const numbers$:Observable = of([1,2,3]); const strings: string[] = ["a","b"
对于我的 Android 应用程序,我需要一个 Observable 来聚合来自 7 个不同搜索的结果并作为一个集合发出。 对于最终发射,我选择了 ListMultimap其中 Content是搜索结
我正在使用改造 2.0.0-beta2 并且调试构建工作正常,但我在使用 Proguard 发布构建时遇到以下错误。 这是更新后的 logcat 错误。 11-17 18:23:22.751 1627
observer.throw(err) 和 observer.error(err) 有什么区别? 我正在使用 RxJS 版本“5.0.0-beta.12” var innerObservable =
我们有一种情况,对服务的方法调用返回一个 IObservable但我们的客户期望 IObservable .将 T1 转换为 T2 很简单。 Rx 中有什么允许这样做的吗? (即链接观察者) 我知道我
我陷入了如何将以下可观察类型转换/转换为我的目标类型的困境: 我有可观察的类型: Observable>> 我想将其转换为: Observable> 所以当我订阅它时,它会发出 List不是Obser
我是一名优秀的程序员,十分优秀!