Вопросы по теме 'cats-effect'

Приложение logback.xml не используется с кошками IOApp
У меня есть приложение scala, которое использует клиентскую библиотеку AWS Kinesis. Я использую logback с кодировщиком logstash для форматирования журналов из моего приложения и KCL как JSON. Мое приложение также написано с использованием...
142 просмотров

Как писать хвостовые рекурсивные функции при работе внутри монад
В общем, у меня проблемы с пониманием того, как писать хвостовые рекурсивные функции при работе «внутри» монад. Вот краткий пример: Это небольшой пример приложения, которое я пишу, чтобы лучше понять 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 просмотров

Остановить длительный процесс на ресурсе
У меня есть ресурс, который выполняет потенциально длительную операцию блокировки. В реальном коде это процедура 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 просмотров

Каково текущее состояние обработки ошибок ввода-вывода с кошками-эффектами?
Я много просматривал эту тему. Только что из stackoverflow я нашел лучший исчерпывающий пост Попробуйте [Результат], ввод-вывод [Результат], Либо [Ошибка, Результат], который я должен использовать в конце Как добавить правильную обработку...
77 просмотров
schedule 22.06.2023

что такое cats / fs2, эквивалент ScheduledExecutorService.scheduleWithFixedDelay
Я нашел fs2-cron , но это не то же самое, что вызов задачи с фиксированным интервалом задержки. Если эта функция доступна в cats / fs2, не могли бы вы предоставить пример кода. Я смотрел на таймер котов, но не мог понять, как повторить задание с...
52 просмотров
schedule 18.05.2022