Вопросы по теме 'cats-effect'
Приложение logback.xml не используется с кошками IOApp
У меня есть приложение scala, которое использует клиентскую библиотеку AWS Kinesis.
Я использую logback с кодировщиком logstash для форматирования журналов из моего приложения и KCL как JSON.
Мое приложение также написано с использованием...
142 просмотров
schedule
29.06.2023
Как писать хвостовые рекурсивные функции при работе внутри монад
В общем, у меня проблемы с пониманием того, как писать хвостовые рекурсивные функции при работе «внутри» монад. Вот краткий пример:
Это небольшой пример приложения, которое я пишу, чтобы лучше понять FP в Scala. Прежде всего пользователю...
987 просмотров
schedule
10.10.2022
Как выполнить метод репозитория Spring для понимания с неявным
Я хочу сохранить данные из телеграммы API для понимания типа с неявным, но есть ошибка
Error:(61, 9) type mismatch;
found : cats.effect.IO[Unit]
required: scala.concurrent.Future[?]
_ <- IO(userRepository.save(User(msg.from.get.id,...
49 просмотров
schedule
21.02.2023
Остановить длительный процесс на ресурсе
У меня есть ресурс, который выполняет потенциально длительную операцию блокировки. В реальном коде это процедура ZeroMQ, ожидающая следующего сообщения (не слишком отличается от кода примера здесь ), но в этом примере я создал фиктивный цикл,...
275 просмотров
schedule
18.09.2023
ParTraverse не является значением NonEmptyList
Я следую инструкциям на веб-сайте Cats IO, чтобы запустить последовательность эффектов параллельно:
Мой код выглядит так:
val maybeNonEmptyList: Option[NonEmptyList[Urls]] = NonEmptyList.fromList(urls)
val maybeDownloads:...
159 просмотров
schedule
25.08.2022
Как преобразовать `List[IO[Unit]]` в `Stream[IO,Unit]`
У меня есть List[IO[Unit]] , состоящий из отдельных произведений, закодированных в IO . Я хотел бы преобразовать его в Stream[IO,Unit]
В настоящее время я сделал это
val works: List[IO[Unit]]
works.map(work =>...
202 просмотров
schedule
28.08.2023
Невозможно создать экземпляр Read для типа User. Непонимание типа с Doobie в Scala
Я пытаюсь вернуть запись пользователя из базы данных, используя doobie, http4s и cats. Я оказался в тупике из-за системы типов, которая выдает следующую ошибку на основе приведенного ниже кода:
роутер:
val httpRoutes = HttpRoutes.of[IO] {...
471 просмотров
schedule
01.01.2023
Повышение производительности потока fs2 с преобразованием файлов
У меня есть что-то вроде этого (это пример из https://github.com/typelevel/fs2 , с моими дополнениями, которые я пометил комментариями):
import cats.effect.{Blocker, ExitCode, IO, IOApp, Resource}
import fs2.{io, text, Stream}
import...
334 просмотров
schedule
14.04.2022
Как на самом деле работает монада IO с кошачьим эффектом?
Я новичок в функциональном программировании и Scala, и я проверял структуру Cats Effect и пытался понять, что делает монада IO. Пока что я понял, что написание кода в блоке ввода-вывода — это просто описание того, что нужно сделать, и ничего не...
264 просмотров
schedule
18.03.2024
Каково текущее состояние обработки ошибок ввода-вывода с кошками-эффектами?
Я много просматривал эту тему.
Только что из stackoverflow я нашел лучший исчерпывающий пост
Попробуйте [Результат], ввод-вывод [Результат], Либо [Ошибка, Результат], который я должен использовать в конце
Как добавить правильную обработку...
77 просмотров
schedule
22.06.2023
что такое cats / fs2, эквивалент ScheduledExecutorService.scheduleWithFixedDelay
Я нашел fs2-cron , но это не то же самое, что вызов задачи с фиксированным интервалом задержки. Если эта функция доступна в cats / fs2, не могли бы вы предоставить пример кода. Я смотрел на таймер котов, но не мог понять, как повторить задание с...
52 просмотров
schedule
18.05.2022