У меня есть рабочий процесс, после которого мне нужно асинхронно очистить его, не теряя при этом значения завершения или состояния сбоя. По сути, мне нужен метод onComplete(), который возвращает завершение.
В Java CompletableFuture мы делаем:
Код: Выделить всё
//...
.handle((v,t) -> cleanup(t) // cleanup needs to know if there was an error
.thenCompose(t == null ? completedFuture(v) : failedFuture(t)))
.compose(f -> f)
Что, признаюсь, довольно ужасно, но работает. Но я не могу найти хороший обходной путь с использованием API Vert.x 5 Future — есть метод в конечном итоге(), но он совершенно не знает о статусе завершения, с которым он составлен, поэтому он не может запустить нашу очистку(t).
Подробнее здесь:
https://stackoverflow.com/questions/798 ... on-regardl