У меня есть Alpakka Elasticsearch Sink
, который я храню между запросами. Когда я получаю запрос, я создаю Source
из HTTP-запроса и превращаю его в Source
Elasticsearch WriteMessage
, а затем запускаю его с mySource.runWith(theElasticseachSink)
.
- Как мне получить уведомление, когда источник будет завершен? Кажется, ничего полезного не материализовалось.
- Будет ли завершение источника передаваться в приемник, то есть мне придется каждый раз создавать новый?
- Если да, поможет ли как-то разъединить их с помощью
Flow.fromSourceAndSink
?
Моя цель - узнать, когда загрузка HTTP завершена (включая via
s, через которые она проходит), и иметь возможность повторно использовать приемник.