Публикации по теме 'fs2'


Составление ресурсов с потоками FS2
Иногда нам нужно, чтобы ресурс был доступен до тех пор, пока происходит обработка некоторого потока FS2. Когда мы говорим о ресурсе, мы имеем в виду что-то, что имеет жизненный цикл, поэтому его необходимо приобретать и освобождать. Библиотека Cats Effect предлагает абстракции для этих шаблонов. Раз так, мы можем представить себе, что должен существовать простой способ компоновки ресурса с потоком, чтобы он был доступен до тех пор, пока мы выполняем обработку потока, и мы освобождаем..

Как написать приложение для обработки данных в FS2
В своей предыдущей статье я обсуждал, как написать приложение для обработки данных с классическими акторами Akka. В этой статье я хотел бы переключиться между передачами и использовать потоковую библиотеку функционального программирования FS2 для обработки журналов HTTP из файла CSV, чтобы получить номера состояний HTTP, которые есть в файле журнала. Я обнаружил, что изучение FS2, в целом, немного сложно, особенно если учесть, что вы никогда не слышали о потоке. Поэтому, прежде чем..

Вопросы по теме 'fs2'

Как распараллелить краулер REST API в http4s и fs2?
Я написал последовательный поисковый робот REST API в http4s и fs2 здесь: https://gist.github.com/NicolasRouquette/656ed7a2d6984ce0995fd78a3aec2566 Это делается для запроса службы REST API для получения начального набора идентификаторов,...
637 просмотров
schedule 16.06.2022

Как создать дискретные потоки в функциональном потоке fs2 для Scala?
Можно ли создать поток дискретных событий в fs2 ? если да как это сделать. Я только начал играть с библиотекой и знаю, что мне есть чему поучиться. Но я не вижу ни одного связанного с этим примера. например Я хочу создать поток для « mousemove »...
479 просмотров

как преобразовать поток scala fs2 в строку?
Я хочу знать, как преобразовать Scala fs2 Stream в строку из примера fs2 github readme: def converter[F[_]](implicit F: Sync[F]): F[Unit] = { val path = "/Users/lorancechen/version_control_project/_unlimited-works/git-server/src/test/resources"...
2620 просмотров
schedule 30.03.2023

Как программно завершить работу fs2.StreamApp?
Расширение StreamApp просит вас предоставить stream def. Имеет параметр requestShutdown . def stream(args: List[String], requestShutdown: F[Unit]): Stream[F, ExitCode] Я предоставляю для этого реализацию и понимаю, что args передается...
1057 просмотров
schedule 18.10.2022

Как преобразовать Stream[IO, List[A]] в Stream[IO, A]
Я хочу проанализировать файл json, который выводит коллекцию A . Подпись Output IO[List[A]] Как преобразовать это значение в Stream : Stream[IO, A] ? Я могу преобразовать в Stream[IO, List[A]] , но это не то, что я хочу...
1384 просмотров
schedule 17.10.2022

Остановить fs2-поток по истечении таймаута
Я хочу использовать функцию, аналогичную take(n: Int) , но во временном измерении: consume(period: Duration . Поэтому я хочу, чтобы поток прервался, если произойдет тайм-аут. Я знаю, что могу скомпилировать поток во что-то вроде IO[List[T]] и...
1068 просмотров
schedule 14.06.2023

Разница между flatMap, flatTap, evalMap и evalTap
В библиотеке Scala fs2 для функциональных потоков: Я пытаюсь понять разницу между flatMap , flatTap , evalMap и evalTap . Кажется, что все они выполняют одно и то же — преобразование значений потока. В чем разница и когда каждый из них...
2356 просмотров

FS2 передает ресурс (или эффект) как состояние
Пытаюсь реализовать приложение, управляющее камерой. Команды камеры представлены в виде потока объектов CameraAction: sealed trait CameraMessage case object Record(recordId: String) extends CameraMessage case object Stop extends CameraMessage...
530 просмотров
schedule 22.05.2022

Scala fs2: что делают FreeC и Algebra?
Когда я перехожу к реализации потоковых операций fs2, я часто вижу, что там используются fromFreeC и Algebra . Что именно делают fromFreeC и Algebra ? Зачем и когда они нужны? Вот пример, операция потока fs2 eval , которая оценивает...
82 просмотров

Запись элементов в файл по мере их удаления из очереди: Scala fs2 Stream
У меня есть небольшой тест потоков fs2, элементов процесса, ожидания, а затем записи их в файл. Я получаю сообщение об ошибке типа и не могу понять, что это означает: Ошибка: required: fs2.Stream[[x]cats.effect.IO[x],Unit] =>...
265 просмотров
schedule 28.03.2023