Блог

я хочу отложить выделение из наблюдаемого на основе длительности элемента из внутреннего массива и распечатать это значение продолжительности; идентификатор в subscribe?

 [{id:1000},{id:2000},{id:3000},{id:4000}]
                  .map(x => of(x).pipe(delay( x.id)) )            
                     .subscribe(x=>{ console.log (x.id)});
  

Я думаю, вы близки … если вы хотите проецировать каждое событие в новую наблюдаемую, тогда вам нужно использовать mergeMap вместо map .

 import { from, of } from 'rxjs'
import { delay, mergeMap } from 'rxjs/operators'

let events = [{id:1000}, {id:2000}, {id:3000}, {id:4000}]

from(events).pipe(
  mergeMap(event => of(event).pipe(
    delay(event.id),
  )),
).subscribe(event => { console.log(event.id) })
  

Но обратите внимание, что mergeMap каждое событие будет выполняться параллельно. Для вашего очень конкретного примера это означало бы, что каждое событие выводится с задержкой всего в 1 секунду между ними. Весь наблюдаемый объект завершится в общей сложности за 4 секунды.

Если вы хотите, чтобы задержка была временем между событиями, тогда вы хотели бы обрабатывать каждое последовательно. Вы могли concatMap бы посмотреть на это:

 import { from, of } from 'rxjs'
import { delay, mergeMap } from 'rxjs/operators'

let events = [{id:1000}, {id:2000}, {id:3000}, {id:4000}]

from(events).pipe(
  concatMap(event => of(event).pipe(
    delay(event.id),
  )),
).subscribe(event => { console.log(event.id) })
  

Опять же, для вашего очень конкретного примера, приведенное выше будет ждать на одну секунду дольше каждый раз между событиями. Это наблюдаемое завершится в общей сложности за 10 секунд.