Я ищу наиболее элегантную реализацию import scalaz.zio.Task def combineTasks[A, B, C, D](task1: Task[Option[A]], task2: Task[Option[B]], task3: Task[Option[C]])...

Я знаю, что FiberRef является эквивалентом Javas ThreadLocal с поддержкой волокна. Однако как я могу сохранить информацию о волокне для побочного кода? По сути, то, что я ищу, похоже на monix.execution. misc.Local , чтобы сделать что-то в...

Мой старый код поддерживал использование одной очереди SQS с SqsStream. Мне нужно обновить его для поддержки нескольких очередей с учетом списка URL-адресов очереди. Содержание метода: for { sqs <- Sqs.>.async // async client urls...

Я пытаюсь создать сервис, объединяющий ZIO и http4s. Отправной точкой является этот пример (использует zio 1.0.1, http4s 0.21.3, scala 2.12.11) Мне удалось собрать приведенный ниже код без каких-либо проблем с использованием sbt , но у меня...

Я не мог найти ничего о том, как игнорировать Suite или Test с помощью ZIO Test. Будь то в примере или в документации ( https://zio.dev/docs/usecases/usecases_testing ) В test package object есть ignored : /** * Creates an ignored...

У меня есть пара Booleans , которые я хочу протестировать, например assert(g8Exists, equalTo(true)) && assert(projectExists, equalTo(true)) && assert(testenvExists, equalTo(true)) ... В случае неудачи все, что я получаю, это:...

Я пытаюсь имитировать службу, у которой есть общий метод, но я не могу понять, как определить эффект в макете. Может ли общий эффект работать? Есть ли обходные пути? Сервис: object AService { type AService = Has[Service] trait Service {...

Пытаясь научиться пользоваться библиотекой ZIO, я решил создать базовое приложение веб-службы. Идея довольно проста, используйте http4s lib для конечных точек сервера и маршрута, выведите «hello world» при вызове конечной точки. С помощью...

У меня есть следующая функция, которую я хочу протестировать: def people(id: Int): RIO[R, People] Эта функция возвращает людей, если для этого есть id , соответственно. не работает, если нет, например: IO.fail(ServiceException(s"No...

Я издеваюсь над следующей функцией: def deploy(deployRequest: DeployRequest, mergeResults: Seq[MergeResult]): Task[Deployment] Для результата мне не важны входы. Итак, мой вопрос, есть ли способ добиться этого с помощью zio.test.mock ....

У меня есть следующий код: import zio._ import scala.concurrent.Future case class AppError(description: String) extends Throwable // legacy-code imitation def method(x: Int): Task[Boolean] = { Task.fromFuture { implicit ec =>...

Я пробую scala.js с zio, используя образец приложения по адресу https://github.com/wongelz/zio-scalajs-solarsystem как только я обновляю версию sbt с 1.2.8 до 1.3.13 или 1.4.4, я получаю следующую ошибку: [error] Referring to non-existent...

У меня два Http4s маршрута: val routes1:HttpRoutes[Task] = ??? val routes2:HttpRoutes[RTask] = ??? Где RTask - это просто Task/RIO с настраиваемой средой: type RTask[A] = RIO[Env,A] Составление двух маршрутов с одинаковыми...