代码之家 › 专栏 › 技术社区 › 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) .

推荐文章

Ole · 在使用新的Angular Resource API时取消搜索术语?

6 月前

koque · 为什么我的RxJs主题没有按预期工作?

6 月前

Raphaël VO · 不使用Observable的初始值

6 月前

xarielah · 从app.config.ts调用时,BehaviorSubject不会更新

10 月前

Lenni · 返回信号并在Angular中订阅它

11 月前

dman · 在Angular单元测试中似乎无法模拟行为主体

11 月前

Nevyan Dimitrov Neykov · 效果内部的角度信号()

11 月前

Ð¤ÐµÐ´Ñ Ð Ð°Ð²ÑÐµÐµÐ² · 如何在react-js中使用Date()在后台增加变量?

11 月前

Ryley38 · 如何跳过流的第一个值,除非它是RxJS的复制粘贴?

1 年前

techwestcoastsfosea · Angular 18-RxJS:Subscribe已弃用[重复]

1 年前