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

完成rxjs可观察区间的正确方法?

observable rxjs

xaisoft · 技术社区 · 7 年前

我的场景是通过aws sdk将记录集添加到主机区域。添加记录集时,aws sdk具有 GetChange 可用于获取该状态的呼叫。以下是我目前正在执行的代码:

  this._adminService.registerDomain(caseWebsiteUrl.Url).
    subscribe(id => {
      return Observable.interval(5000).flatMap(() => {
        return this._adminService.getChange(id);
      }).
        takeWhile((s) => s.ChangeInfo.Status.Value !== 'INSYNC').subscribe(
        () => {

        },
        () => {

        },
        () => this.urlStatus = 'fa fa-check');

    });

registerDomain 成功之后,我想打电话 getChange 每一个 5 seconds Status.Value !== 'INSYNC'

几个问题:

flatMap在做什么?
如果我不需要next或error回调,但需要完整的回调,那么有必要声明空体吗?

1 回复 | 直到 7 年前

Mark van Straten 7 年前

Flatmap又名MergeMap,将使高阶观测值变平。因此 Observable<Observable<T>> => Observable<T>

subscribe内部的subscribe是一种代码味道,可以而且应该重构。如果不需要错误/完整处理程序,则不需要传递这些处理程序。例如:

 function registerDomain(caseWebsiteUrl) {
    return this._adminService.registerDomain(caseWebsiteUrl.Url)
      .concatMap(registerId => Observable.interval(5000)
        .mergeMap(() => this._adminService.getChange(registerId))
        .takeWhile((info) => info.ChangeInfo.Status.Value !== 'INSYNC')
      )
  }
  registerDomain.subscribe(res => console.log('res:'+res));

这基于以下假设和限制:

registerDomain()
getChange()
未添加错误处理(例如30秒后超时?如果需要,请重试 registerDomain()

推荐文章

Anjil Dhamala · 在收到特定http状态时重试http调用

6 年前

simonberry · 取消RXJS FlatMap链上的订阅

6 年前

user9487981 · 可以激活防护装置并使用角度为5的可见光

6 年前

makat · 角度5 HTTP请求间隔使用可观察值,而值可能会更改

6 年前

Gissipi_453 · 在RxJava 2中的可观察对象中发出字符串数组时出现“不兼容类型”错误

6 年前

Jake Shakesworth · 如何将一个可观察对象映射到另一个可观察对象

6 年前

Nomura Nori · 许诺仅当使用了4个以上的承诺时,才获得“Access Control Allow Origin”

6 年前

MindlessRouse · 路由解析程序在没有订阅的情况下不触发可观察

6 年前

DevMike · 在角度服务中,如果在可观测范围内使用贴图功能,那么假设贴图功能保证同步是否正确?

6 年前

Arun Prasad E S · 角度5,离子3-【ts】类型“void”不可分配给类型“Observable<Post[]>”

6 年前