futures

Есть текстовый файл с базой сайтов > 100k, может кто-нибудь подсказать как грамотно организовать параллельную обработку в функциональном стиле с целью отфильтровать неактивные? С помощью Future или AkkaStreams Мои попытки: @throws(classOf[java.io.IOException]) def get(url: String) =...