链中具有多个 filter() 和 switchMap() 运算符的 Rxjs 管道函数

Question

我正在重构一些旧的 rxjs 代码，这些代码写得不好，因此有一些竞争条件。

所以我想根据各种条件使用一系列 filter() 运算符；但是我需要它来访问这条链上的每个过滤器操作符。即，如果 Condition1 为真，则执行下一个 switchMap() - 否则继续执行下一个 filter()。将相同的逻辑应用于 Condition2..Condition4.

此外，我的 selectedNode 需要沿着链发出，因为 getChildNodes() 函数获取额外的子节点并将它们推送到选择的节点.

现在 它只是在遇到第一个 FALSY 条件时停止 - 所以自然不会检查其余过滤器。

如何使 if 在每个条件下都作为旧的 IF...THEN 语句执行？

这是我目前的情况：

    constructor(private readonly configSvc: ConfigService) {
        this.model$
            .pipe(
                filter((selectedNode) => !!selectedNode),

                // if condition1 passes, get child nodes of current node.
                filter((selectedNode) => myCondition1),
                switchMap((selNode) => this.getChildNodes(selNode, NodeType.Type1)),

                // if condition2 passes..
                filter((selectedNode) => myCondition2),
                switchMap((selNode) => this.getChildNodes(selNode, NodeType.Type2)),

                // if condition3 passes..
                filter((selectedNode) => myCondition3),
                switchMap((selNode) => this.getChildNodes(selNode, NodeType.Type3)),

                // if condition4 passes, get child nodes...
                filter((selectedNode) => myCondition4),
                switchMap((selNode) => this.getChildNodes(selNode, NodeType.Type4)),

                takeUntil(this.onDestroy),
            )
            .subscribe({
                next: (selectedNode: SelectedNode) => { // init the Network tree and notify listeners
                    this.initNetwork(selectedNode);
                    this.configNodesReadySource.next(selectedNode);
                },
            });
    }

或者订阅 mult observables，一个替代想法：

const condition1$ = this.model$.pipe(filter((node) => condition1), switchMap(...);
const condition2$ = this.model$.pipe(filter(...), switchMap(...);
const condition3$ = this.model$.pipe(filter(...), switchMap(...);
const condition4$ = this.model$.pipe(filter(...), switchMap(...);

forkJoin(...).subsribe(...); // join condition1 thru 4 to get final result ???

但是，我似乎遇到了相同或类似的问题。我从来没有达到订阅。

Answer 1

您可以使用concatMap实现所描述的级联

this.model$
.pipe(
    filter((selectedNode) => !!selectedNode),
    concatMap(selectedNode => myCondition1 ? this.getChildNodes(selectedNode, NodeType.Type1) : of(selectedNode)),
    concatMap(selectedNode => myCondition2 ? this.getChildNodes(selectedNode, NodeType.Type2) : of(selectedNode)),
    concatMap(selectedNode => myCondition3 ? this.getChildNodes(selectedNode, NodeType.Type3) : of(selectedNode)),
    concatMap(selectedNode => myCondition4 ? this.getChildNodes(selectedNode, NodeType.Type4) : of(selectedNode)),
    takeUntil(this.onDestroy),
)
.subscribe({
    next: (selectedNode: SelectedNode) => { // init the Network tree and notify listeners
        this.initNetwork(selectedNode);
        this.configNodesReadySource.next(selectedNode);
    },
});

链中具有多个 filter() 和 switchMap() 运算符的 Rxjs 管道函数

Rxjs pipe function with multiple filter() and switchMap() operators in the chain

angular

rxjs-pipeable-operators

rxjs-filter