如何将RxJs角码写入RxDart

Question

如何用颤振RxDart编写以下RxJ角码。

  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;
  });

}

Answer 1

粗略地看一下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;
  }

}