如何将RXJS角度代码写入rxdart

发布于 2025-01-22 06:49:41 字数 481 浏览 4 评论 0原文

如何在Flutter RXDART中编写以下RXJS角度代码。

  callConcatMapPayload(apiPostData) {
of(...apiPostData) // here of() is creational operator from RxJs (Observable)
  .pipe(
    concatMap((params) =>
      this.controlService.apipostHttpRequest(
        params.url,
        params.headers,
        params.data
      )
    )
  )
  .subscribe((res) => {
    this.bindHiddenArray(res, apiPostData, this.multiapiindex);
    this.multiapiindex += 1;
  });

}

How can i write the following RxJs Angular code in Flutter RxDart.

  callConcatMapPayload(apiPostData) {
of(...apiPostData) // here of() is creational operator from RxJs (Observable)
  .pipe(
    concatMap((params) =>
      this.controlService.apipostHttpRequest(
        params.url,
        params.headers,
        params.data
      )
    )
  )
  .subscribe((res) => {
    this.bindHiddenArray(res, apiPostData, this.multiapiindex);
    this.multiapiindex += 1;
  });

}

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

很酷不放纵 2025-01-29 06:49:41

从粗略地瞥见RXDART的文档,我想这应该有效。当然,您必须对其进行测试。

callConcatMapPayload(apiPostData){

  const s = fromIterable(apiPostData)
    .flatMap(({url, headers, data}) => fromFuture(
      this.controlService.apipostHttpRequest(url, headers, data)
    ))

  await for (let res in s) {
    this.bindHiddenArray(res, apiPostData, this.multiapiindex);
    this.multiapiindex += 1;
  }

}

From a cursory glance at the docs for RxDart, I would guess this should work. You'll have to test it of course.

callConcatMapPayload(apiPostData){

  const s = fromIterable(apiPostData)
    .flatMap(({url, headers, data}) => fromFuture(
      this.controlService.apipostHttpRequest(url, headers, data)
    ))

  await for (let res in s) {
    this.bindHiddenArray(res, apiPostData, this.multiapiindex);
    this.multiapiindex += 1;
  }

}
~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文