даю на вход список файлов (List[File]) и ожидаю, что после фильтрации у меня запишутся только те файлы, который соблюдают условие. Но создаются у меня абсолютно все файлы.
(for {
file <- files
name = file.getName
} yield Files[IO]
.readAll(file.toPath, 4096)
.through(text.utf8Decode)
.map {
case "some" ⇒
Some("some")
case _ ⇒
None
}
.collect { case Some(s) => s }
.through(text.utf8Encode)
.through(Files[IO].writeAll(outputDir.resolve(name + ".result")))
.compile
.drain).sequence
writeAll не лениво создаёт файл, а при создании пайпа? что-то это странно как-то
Ну это ИМО не более странно, чем попросить создать файл с определенным контентом, а потом не найти этот файл.
я не понял мысль. Я беру список файлов, фильтрую по какому-то условию, обрабатываю и пишу потом только те, которые мне нужны. Что в этом странного
так у вас Files[IO].writeAll(outputDir.resolve(name + ".result") вот тут используется name из фора, нет?
Вы не хотите создавать файл, если стрим пустой. Это не странное желание. Но writeAll - это библиотечная функция. Вы удивляетесь, что она работает не так. Ну я утверждаю, что создавать пустой файл для нее - нормальное поведение. Если его изменить, то удивленных людей будет не меньше, а больше.
Обсуждают сегодня