按顺序调用observable.subscribe（）

Question

我有一个object的数组，我希望循环访问该数组并为每个元素调用服务，但对于每个元素，我希望只有当当前调用成功时才调用下一个元素，除非阻塞其余的。

    onUpload(items: MyItem[]) {
      items.forEach(i => {
        myService.doSomething(i).subscribe(response => {
          // do something with the success item i
          // do the next call for the next item 
        }, error => {
          // handle the error
        })
      })

     }

有没有在序列模式下调用可观察到的数据而不是并行的？

Answer 1

使用from从数组中发出值，然后使用contactmap顺序执行可观察值

import { from } from 'rxjs';
import { concatMap } from 'rxjs/operators';

onUpload(items: MyItem[]) {
  from(items)
    .pipe(
       concatMap(item => myService.doSomething(i))
    )
    .subscribe(response => {/* do something with response */});
}