代码之家 › 专栏 › 技术社区 › POV

在RX中使用平面图的正确方法?

rxjs5 rxjs angular

POV · 技术社区 · 6 年前

是正确的使用方法吗 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() 从服务器返回数据。

当我得到成功的答复时,我就完成了这项工作。是真的吗?

1 回复 | 直到 6 年前

Hero Wanders 6 年前

我不确定我是否正确理解您,但您的代码执行以下操作: 方法 askToReadyRecordVideo 将每3秒被呼叫一次,直到10秒结束(将有3个呼叫,分别为3、6和9)。你的可观察的 observer 将发出这些服务器调用的结果。

如果要在第一次成功响应后取消进程,请添加以下内容:

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

如果每一个答案都是成功的(即通过可观察到的错误事件指示错误),那么只需省略 filter 线。

顺便说一句:传递回拨电话时要小心,以避免对 this 意味着在 askToReadyRecordVideos . 你可以用 flatMap(() => this.askToReadyRecordVideo()) 或 flatMap(this.askToReadyRecordVideo.bind(this)) 而不是 flatMap(this.askToReadyRecordVideo) .

推荐文章

Fahad Subzwari · 我不能用rxjs过滤器过滤记录?

2 年前

Fazla Elahi Md Jubayer · 在rxjs中使用管道内的两个concatmap时,如何提取订阅块内的结果

2 年前

Irakli · 我想以角度显示id相似的数据

2 年前

Akash · 当BehaviorSubject发出两次真值时,使ngOnChange被激发

6 年前

Shamshiel · 将rxjs升级到6后,类型“Observable”上不存在属性“map”

6 年前

Corey Cole Roberto Tyley · 使用RxJS 6。x WebSocketSubject客户端

6 年前

gog · 如何观察rxjs中的属性更改?

6 年前

jesdynf · 在继续之前,如何使角度拦截器延迟?

6 年前

Sean Ivins · 角度2+HttpIntercept:在返回intercept函数之前,等待来自服务器的令牌

6 年前

Kevin Kalitowski · RxJs 6:从Observable获取ConnectableObservable

6 年前