在 Rx 中使用 FlatMap 的正确方法？

Question

flatMap的使用方法正确吗？

const observer = Observable
    .interval(3000)
    .takeUntil(Observable.timer(10000))
    .flatMap(this.askToReadyRecordVideo);

private askToReadyRecordVideo(): Observable<any> {
    return this.requestMethods.askToReadyRecordVideo({});
}

在这一行中，我绑定了每 3 秒向服务器发送一次请求，直到 10 秒，然后调用从服务器返回数据的方法 this.askToReadyRecordVideo()。

当我得到成功响应时，我完成了这个。是真的吗？

Answer 1

我不确定我是否理解正确，但您的代码执行以下操作： askToReadyRecordVideo 方法将每 3 秒调用一次，直到 10 秒结束（将在 3 秒、6 秒和 9 秒时调用 3 次）。 您的 observable observer 将发出这些服务器调用的结果。

如果您想在第一次成功响应后取消该过程，请添加以下内容：

.filter(resp => /* return true when resp indicates success */)
.take(1)

如果每个答案都是成功的（即错误由通过 observable 推送的错误事件指示），那么只需省略 filter 行。

顺便说一句：传递回调时要小心，以免对this 在askToReadyRecordVideos 中的含义感到意外。您可以使用flatMap(() => this.askToReadyRecordVideo()) 或flatMap(this.askToReadyRecordVideo.bind(this)) 代替flatMap(this.askToReadyRecordVideo)。