RxJS：扫描操作员内切换地图/合并地图

Question

我们正在使用扫描操作符来执行表中的“加载更多”按钮。使用scan操作符，我们只需将新结果与以前的结果相加。然而，我们遇到了一些意想不到的行为。

为了简化，假设我们有以下代码：

const fakeRequest = of('response').pipe(delay(2000));
interval(1000).pipe(
    mergeMap(_ => fakeRequest),
    scan<string>((allResponses, currentResponse) => [...allResponses, currentResponse], []),
).subscribe(console.log);

生产：

["response"]
["response", "response"]
["response", "response", "response"]
["response", "response", "response", "response"]
...

而如果我们只是将扫描操作符移动到mergeMap/switchMap操作符中：

interval(1000).pipe(
    mergeMap(_ => fakeRequest.pipe(
        scan<string>((allResponses, currentResponse) => [...allResponses, currentResponse], []),
    )),
).subscribe(console.log);

我们得到以下结果：

["response"]
["response"]
["response"]
["response"]
...

在第二个示例中，未执行扫描运算符。我希望switchMap/mergeMap只是将内部的可观察对象展平，扫描操作符通过管道插入其中。

• 这是期望的行为吗？
• 如果是这样，有人能解释为什么会这样吗？
• 如果是这样，是否有其他方法/工作方法在mergeMap或SwitchMap运算符中实现相同的行为？

谢谢

Answer 1

产生差异的原因是，在第一种情况下：

interval(1000).pipe(
    mergeMap(_ => fakeRequest),
    scan<string>((allResponses, currentResponse) => [...allResponses, currentResponse], []),
)

您正在扫描mergeMap中创建的所有可见光的发射。

然而，在第二种情况下：

interval(1000).pipe(
    mergeMap(_ => fakeRequest.pipe(
        scan<string>((allResponses, currentResponse) => [...allResponses, currentResponse], []),
    )),
)

你正在扫描一个只发射一次的可观测物体的发射！

本质上，mergeMap（）是一个多次发射的源。fakeResponseobservable是一个只发射一次的源。

我从您的评论中看到，您希望在响应下移动扫描的原因是希望在您的服务中执行扫描，因此个人消费者不需要这样做。我知道这是一个老问题，所以也许你现在已经解决了这个问题，但是你当然可以在你的服务中执行扫描逻辑（只要你的间隔（）也在那里），方法是在一个上添加。管道（扫描（...））。