169 похожих чатов

Что-То не получается справиться с функцией writeAll в fs2. Я

даю на вход список файлов (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 не лениво создаёт файл, а при создании пайпа? что-то это странно как-то

4 ответов

12 просмотров

Ну это ИМО не более странно, чем попросить создать файл с определенным контентом, а потом не найти этот файл.

Dimas-Shakhtarin Автор вопроса
Evgenii Kuznetcov
Ну это ИМО не более странно, чем попросить создать...

я не понял мысль. Я беру список файлов, фильтрую по какому-то условию, обрабатываю и пишу потом только те, которые мне нужны. Что в этом странного

так у вас Files[IO].writeAll(outputDir.resolve(name + ".result") вот тут используется name из фора, нет?

Dimas Shakhtarin
я не понял мысль. Я беру список файлов, фильтрую п...

Вы не хотите создавать файл, если стрим пустой. Это не странное желание. Но writeAll - это библиотечная функция. Вы удивляетесь, что она работает не так. Ну я утверждаю, что создавать пустой файл для нее - нормальное поведение. Если его изменить, то удивленных людей будет не меньше, а больше.

Похожие вопросы

Обсуждают сегодня

А чем вам питонисты не угодили?😂
.
79
Язык Си можно выучить за день? По книжке ANSI C на 230 страниц
Vincent Vegan
29
Всем привет, написал код ниже, но он выдает сегфолт, в чем причина? #include <stdio.h> #include <stdlib.h> #include <string.h> struct product { char *name; float price; };...
buzz базз
75
Есть какой-нибудь для Delphi/FPC T*Compression(Decompression)Stream на базе LZ4/Zstd/любой другой быстрый(и хорошо сжимающий) алгоритм А ещё лучше в pure pascal А ещё лучше од...
notme
18
Dim Dim, [02.07.2024 11:07] DB 0x62 Dim Dim, [02.07.2024 11:07] DB 0x66 Dim Dim, [02.07.2024 11:07] кто пояснит что это?
Dim Dim
14
Ошибка: segmentation fault (core dumped) Код: pastebin.com/BEsNNSSV Сообщение от компилятора: отсутствует ОС: Arch Linux Ядро: x86_64 Linux 6.9.7-arch1-1 Процессор: Intel Cele...
sec
4
Ещё такой вопрос. Мне необходимо хранить пароль пользователя локально. Для этого планирую использовать ini файл. Это для автозаполнения полей логин и пароль при авторизации. Е...
Евгений
19
Ребят, а за скок можно впарить анон чат с апишкой и веб админкой ?
Eugene Неелов
15
Кстати, я тут еще с одной темой столкнулся, вот учу я C++, на таком то ресурсе, а остальные постоянно советуют практиковаться, что то писать, проекты, но как писать если вот т...
aaswq1
7
А как лучше конвертировать физический адрес в виртуальный при маппинге? В случае ядра у меня, например, direct mapping, первые 768МБ я как есть мапплю в higher half, а остальн...
Evg Resh
26
Карта сайта