У меня есть процессор и приемник, который испускает элементы с помощью sink.next ().
Поток может потенциально потерпеть неудачу на одном из шагов, я хочу повторить попытку только неисправного элемента, а не остальных. 
На изображении выше я хочу только переизлучить фиолетовый элемент.