Tag: AKKA-HTTP
Soy nuevo en Akka HTTP y quiero eliminar los campos innecesarios de una respuesta JSON y tomar solo los campos necesarios. Por ejemplo, uso este endpoint this para obtener la respuesta y contiene una gran cantidad de campos. Por el momento, solo necesito ‘name’ y ‘versions’. Me gustaría saber cómo . . . Read more
Estoy recibiendo un Multipart/FromData como servidor. Esta solicitud contiene Source[Multipart.FormData.BodyPart, Any] y cada Multipart.FormData.BodyPart contiene Source[ByteString, Any] en su interior. Soy capaz de establecer un tamaño de búfer. Pero mide en cantidad de elementos. ¿Cómo puedo calcular el tamaño de cada elemento ByteString (tamaño de lote)? Necesito calcular todo el . . . Read more
Puedo acceder a la ruta de la tabla usando: wget http://127.0.0.1:9000/board Ahora, si intento acceder a mi ruta de sesión de esta manera: wget http://127.0.0.1:9000/session/getByToken Recibo este error: –2021-11-30 11:56:12– Resolving localhost (localhost)… 127.0.0.1 Connecting to localhost (localhost)|127.0.0.1|:9000… connected. HTTP request sent, awaiting response… 404 Not Found 2021-11-30 11:56:12 ERROR . . . Read more
Estoy creando un ByteArrayOutputStream utilizando ZIO Streams, es decir: lazy val byteArrayOutputStream = new ByteArrayOutputStream() val sink = ZSink.fromOutputStream(byteArrayOutputStream).contramapChunksString val data = ZStream.unwrap(callToFunction).run(sink) Esto funciona bien, ahora necesito transmitir en streaming estos datos de regreso al cliente utilizando akka http. Puedo hacer esto: val arr = byteArrayOutputStream.toByteArray complete(HttpEntity(ContentTypes.application/octet-stream, arr)) Lo . . . Read more
Tengo el siguiente test: “Fallará si la fecha tiene un formato incorrecto” in { val endpoint = s”/api/prof?date=wrongdate” Get(endpoint) ~> check { status shouldBe StatusCodes.BadRequest val resp = responseAs[String] resp shouldBe “could not be parsed” } } Sin embargo, el test falla con el siguiente mensaje: No se pudo procesar . . . Read more