ngrx - for loop -当前元素的处理完成后获取下一个元素

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

const array = [1, 2, 3, 4, 5];

// 将数组转换为Observable对象
const observable = from(array);

// 使用concatMap操作符处理每个元素，并在处理完成后获取下一个元素
observable.pipe(
  concatMap((value) => {
    // 在这里进行当前元素的处理逻辑
    console.log(`处理元素: ${value}`);
    
    // 模拟处理延迟
    return of(value).pipe(delay(1000));
  })
).subscribe((value) => {
  // 在这里获取下一个元素
  console.log(`获取下一个元素: ${value + 1}`);
});