Публикации по теме 'fs2'
Создание системы регулирования для любого приложения, содержащего не более 100 строк кода
Приложения часто разрабатываются с задействованным механизмом регулирования. Иногда мы хотим ограничить количество запросов, чтобы повысить безопасность и производительность нашего приложения. Иногда ваше приложение не может отвечать более чем на определенное количество подключений. Например, если вы как можно быстрее опросили сообщение из очереди и не ограничили количество подключений, ваше приложение скоро исчерпает свои ошибки подключения и столкнется с ошибкой отказа в..
Вопросы по теме 'fs2'
fs2 Stream scala Нет неявного типа: Stream.Compiler[Eval,G_]
Я пытаюсь создать Stream[Eval, String] следующим образом:
import cats.Eval
import cats.effect.{ExitCode, IO, IOApp}
import fs2._
object StringEval extends IOApp {
def evalString: Eval[String] = Eval.always{
val r = new...
170 просмотров
schedule
24.01.2024
Можно ли разделить чистое состояние FP между несколькими HTTP-запросами на сервере http4s?
Я пытаюсь разделить состояние между несколькими HTTP-запросами на http4s сервере.
Вот что я пробовал:
for {
state <- Ref[F].of(0)
_ <- BlazeServerBuilder[F]
.bindHttp(port, host)
.withHttpApp( ... httpApp...
147 просмотров
schedule
07.02.2024
Изменение типа эффекта fs2.Stream
Я использую doobie, который может создавать fs2.Stream[ConnectionIO, Int] строк базы данных ( Int в моем случае). ConnectionIO[A] - это внутренний тип doobie.
Учитывая HKT F[_] и val nt: ConnectionIO ~> F , есть ли способ получить...
186 просмотров
schedule
05.11.2023
