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: AKKA-HTTP

akka-http – Tamaño de lote de transmisión de Multipart/FormData

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

No puedo acceder a mi ruta de sesiones, hay un problema con mi código DSL de enrutamiento en mi aplicación akka-http.

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

Transmitiendo un ByteArrayOutputStream a una respuesta de Akka HTTP.

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

Akka Route TestKit no pudo deserializar la respuesta como String.

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