Выдавать исходные значения с каждым «тиком» другого наблюдаемого объекта. ⇐ Javascript

[Anonymous]

У меня есть источник Observable, и я хочу отложить выбросы (без пропуска) как таковые: начните с первого выброса, затем для каждого следующего выброса подождите, пока один раз не будет выпущен другой такт Observable.
Это должно сработать:

Код: Выделить всё

source.pipe(
concatMap((value) =>
tick.pipe(
first(),
ignoreElements(),
startWith(actions),
),
),
)

Но у меня такое ощущение, что существует гораздо более простое решение, хотя я перепробовал все операторы, которые только мог придумать (

Код: Выделить всё

audit

, задержка, интервал, образец, ...). sample ближе всего подходит, но пропускает выбросы. Кроме того, проблема сильно напоминает мне планировщики: если бы можно было сделать планировщик из наблюдаемого.


Подробнее здесь: https://stackoverflow.com/questions/798 ... observable