Блог

Я хочу постепенно увеличивать задержку для этого:

 const source = from(839283, 1123123, 63527, 4412454); // note: this is random
const spread = source.pipe(concatMap(value => of(value).pipe(delay(1000)))); // how to incrementally increase the delay where the first item emits in a second, the second item emits in three seconds, the third item emits in five seconds, and the last item emits in seven seconds.
spread.subscribe(value => console.log(value));
  

Я знаю об использовании interval для постепенного увеличения времени задержки, как показано ниже. Но мне также нужно использовать этот источник const source = from(839283, 1123123, 63527, 4412454);

 const source = interval(1000); // But I also need to use have this from(839283, 1123123, 63527, 4412454)
const spread = source.pipe(concatMap(value => of(value).pipe(delay(value * 200))));
spread.subscribe(value => console.log(value
  

Как постепенно увеличивать время задержки при запуске с const source = from(839283, 1123123, 63527, 4412454); ?

Вы можете использовать индекс переданного значения и рассчитать задержку на его основе.

 concatMap((value, index) => {
  return of(value).pipe(delay((index > 2 ? 7 : index) * 1000));
})
  

Вот stackblitz для полного примера с вашим фрагментом:
https://stackblitz.com/edit/rxjs-jjmlta?devtoolsheight=60

Второй параметр concatMap — это индекс, который можно умножить на 1000, чтобы получить последовательность 0, 1000, 2000… Последовательность 1000, 3000, 5000… затем можно создать с помощью 1000 * (i * 2 1) :

 const {concatMap, delay, from, of} = rxjs;

from([839283, 1123123, 63527, 4412454])
  .pipe(concatMap((value, i) =>
    of(value).pipe(delay(1000 * (i * 2   1)))
  ))
  .subscribe(value => console.log(value));  

 <script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/7.5.6/rxjs.umd.min.js"></script>