У меня есть горячая наблюдаемая целых чисел, которые испускают предметы в течение 5 секунд, затем останавливаются в течение 3, а затем снова пускает статистику ...
Что мне нужно, так это когда предметы начинают излучать, ждут 1 секунду, берут последний испущенный предмет, которые ждут последние 4 секунды и 3 секунды паузы, а затем снова ждут 1 секунду, берут последний испущенный элемент и навсегда ...