Как обнаружить пустой источник Akka

Question

В некоторых крайних случаях я возвращаю пустой источник. Есть ли способ для вызывающего абонента проверить, является ли возвращаемый Источник пустым или нет перед его запуском?

Answer 1

Есть ли способ для вызывающего абонента проверить, является ли возвращаемый Source пустым или нет перед его запуском?

Нет.Единственный способ определить, пуст ли Source, - запустить его.

Answer 2

Источник Этап обработки с ровно одним выходом, испускающий элементы данных всякий раз, когда последующие этапы обработки готовы их получить.

По определению мы не можем знать элемент источника, если тольковниз по течению, чтобы получить.

Итак, насколько я понимаю, мы не можем проверить, является ли источник пустым или нет без его запуска.Пожалуйста, не стесняйтесь комментировать ваши мысли

Я думаю, что один из способов достижения этого требования -

val x: Future[Boolean] = Source.empty.runWith(Sink.seq).transform{
   case Success(lst) => Success(lst.isEmpty)
   case Failure(_) => Success(true)
}