Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Actualmente estoy desarrollando utilizando Spring Boot WebFlux. Estoy usando clientes de websocket y clientes de APIs, pero este error ocurre unas horas después de la implementación. No pude determinar de dónde proviene este error. ¿De dónde viene este problema? El registro de error es el siguiente: [reactor-http-epoll-2] r.n.http.server.HttpServerOperations : [9c0c3ede, . . . Read more
No puedo obtener el atributo del objeto ‘is_secure’ en la respuesta JSON, ¿qué está mal con este código? @Configuration class RouterConfiguration( ) { @Bean fun testRoutes(testHandler: TestHandler) = coRouter { GET(“/test”, testHandler::testFunction) } } data class TestClass( val is_secure: Int? = 1, val xyz: String? ) @Component class TestHandler{ suspend . . . Read more
Disculpa mi pregunta tonta. Soy muy nuevo en el proyecto reactor. Y esta pregunta me está molestando mucho. Si flux puede manejar de 0 a N elementos y Mono puede manejar de 0 a 1 elemento, ¿por qué existe el mono? ¿No puede flux manejar también de 0 a 1 . . . Read more
Tengo un servicio que se comunica con otro servicio a través de REST. La llamada está envuelta en un Mono: return Mono.from(buildPublisher(requestDto)) .subscribeOn(Schedulers.boundedElastic()) .onErrorResume(e -> Mono.empty()) .map(this::mapResponse); Necesito hacer decenas de miles de llamadas a ese servicio, así que estoy llamando al método anterior desde aquí: return Flux.fromStream(hugeListOfObjects.stream()) .flatMap(serviceWhichReturnsMono::makeACallAndReturnMono); Funciona . . . Read more
Estoy tratando de hacer algo de nuevo aquí en el proyecto reactor que estoy seguro de que es súper sencillo para cualquiera de ustedes, gurús del proyecto reactor que estén ahí fuera! He estado buscando y rascándome con esto por un tiempo ahora, y siento que una vez más me . . . Read more