Возможно сериализовать поток реакторов. Например, мой Flux находится в каком-то состоянии и в настоящее время обрабатывает какое-то событие. И вдруг услуга прекращается. Текущее состояние Flux сохраняется в базе данных или в файле. И затем при перезапуске приложения я просто беру все Flux из этого файла/таблицы и подписываюсь на них, чтобы перезапустить обработку из последнего состояния. Это возможно в реакторе?Сериализующий поток в реакторе
Нет, это невозможно. Flux не сериализации и ближе к цепочке функций, они не обязательно имеют состояние [1] но описать, что делать данный вход (при условии, начальным производящего Flux) ...
Так для того, чтобы «перезапустить» Flux, вам нужно было бы создать новый, который будет загружать оставшийся исходный текст, который был получен при завершении службы.
Таким образом, было бы больше источников данных, чтобы сохранить последнее испущенное состояние и разрешить перезапуск новых последовательности потоков.
[1] Хотя, в зависимости от того, что операторы вы прикованы, вы могли бы это повлиять на некоторые внешние состояния. В этом случае все усложняется, так как вам также нужно будет сохранить это состояние.