es.davy.ai

Preguntas y respuestas de programación confiables

¿Tienes una pregunta?

Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.

Tag: CATS-EFFECT

Cómo convertir Stream [IO, Int] a ZStream con cats-interop

No soy un programador de Cats Effect, recién he comenzado a aprender ZIO. Así que quiero usar zio.ZStream para manipular datos de un fs2 stream. ¿Cómo puedo convertir Stream[IO, Int] a ZStream con cats-interop? import zio.stream.ZStream import zio.stream.interop.fs2z._ import cats.implicits._ import zio.interop.catz.core._ import zio.interop.catz._ val a: Stream[IO, Int] = ??? . . . Read more

Cómo cancelar un futuro completado con cats effects 3

Este código prueba la cancelación de una fibra creada desde un completable future y está fallando: val toCancel = CompletableFuture.supplyAsync { () => Thread.sleep(20000) () } val test = for { foo <- IO.fromCompletableFuture(IO(toCancel)).start _ <- IO.sleep(1.second) _ <- foo.cancel } yield toCancel.isCancelled assertIOBoolean(test) ¿Es esto un bug de Cats . . . Read more

Cómo simular el método make de MVar2

Tengo problemas para burlar el método <code>MVar2</code> llamado <code>make</code> en mi prueba de unidad (usando mockito). Intenté esto: private val sq = mock[MVar2[IO, String]] y cuando intenté burlar el método así: when(sq.take).thenReturn( “testString”.pure[IO], IO.never ) Obtengo un bucle infinito en la prueba. Estaba seguro de que podía burlarlo de esta . . . Read more

Convertir implicit def a la sintaxis proporcionada en Scala 3.

Para el siguiente generador de UUID aleatorio utilizando cats effect: import java.util.UUID import cats.effect.Sync import cats.ApplicativeThrow trait UuidGen[F[_]]: def make: F[UUID] def read(string: String): F[UUID] object UuidGen: def apply[F[_]: UuidGen]: UuidGen[F] = implicitly implicit def forSync[F[_]: Sync]: UuidGen[F] = new UuidGen[F]: def make: F[UUID] = Sync[F].delay(UUID.randomUUID) def read(string: String): F[UUID] . . . Read more