Я использую Akka Streams и наткнулся на Sink.actorRefWithAck.Я понимаю, что он отправляет сообщение и пытается извлечь другой элемент из потока только после получения подтверждения для предыдущего сообщения.Есть ли способ пакетной обработки сообщений с этим приемником?Пример: извлеките пять сообщений и извлеките следующие пять только после подтверждения первых пяти.Я думал о чем-то вроде
source.grouped(5).to(Sink.actorRefWithAck(...))
Но для этого потребовалось бы изменить приемник для работы с последовательностями, что, предположим, исключено.