Resultados de la búsqueda a petición "reactive-programming"
¿Cómo obtener mejor una matriz de bytes de un ClientResponse de Spring WebClient?
Estoy probando lo nuevoWebClient desde Spring 5 (5.0.0.RC2) en una base de código que usa programación reactiva y he tenido éxito al mapear la respuesta JSON desde un punto final a un DTO en mi aplicación, que funciona muy bien: WebClient client ...
¿Cómo crear un Spring Reactor Flux a partir del flujo de integración Http?
Tengo una pregunta muy parecida a esta.¿Cómo crear un Spring Reactor Flux a partir de una cola ActiveMQ? [https://stackoverflow.com/questions/43126775/how-to-create-a-spring-reactor-flux-from-a-activemq-queue] Con una diferencia, los mensajes ...
¿Cómo “gestionas” realmente el número máximo de hilos web utilizando la Programación Reactiva de Spring 5?
Al usar un enfoque clásico de Tomcat, puede darle a su servidor un número máximo de hilos que puede usar para manejar las solicitudes web de los usuarios. Usando el paradigma de Programación Reactiva y Reactor en Spring 5, podemos escalar mejor ...
¿Por qué Spring ReactiveMongoRepository no tiene un método para guardar Mono?
Tengo un MovieRepository que extendió ReactiveMongoRepository. Quiero guardar un solo POJO de forma reactiva. Pero ReactiveMongoRepository no proporciona un método de guardado para Mono o Publisher. Tengo que usarblock() método o utilizar ...
Mecanismo de contrapresión en Spring Web-Flux
Soy titular enSpring Web-Flux. Escribí un controlador de la siguiente manera: @RestController public class FirstController { @GetMapping("/first") public Mono<String> getAllTweets() { return Mono.just("I am First Mono") } } Sé que uno de los ...
¿Estoy usando plátano reactivo, verdad?
Aquí hay un ejemplo del programa Haskell FRP que usa la biblioteca reactiva-banana. Recién estoy empezando a sentirme bien con Haskell, y especialmente no he entendido bien qué significa FRP. Realmente agradecería algunas críticas al código a ...
Pueden los ciclos de manejo de banana reactiva en la red?
Tenemos un código como este: guiState :: Discrete GuiState guiState = stepperD (GuiState []) $ union (mkGuiState <$> changes model) evtAutoLayout evtAutoLayout :: Event GuiState evtAutoLayout = fmap fromJust . filterE isJust . fmap autoLayout $ ...
Lea continuamente bytestream de Stream usando TcpClient y Reactive Extensions
Considere el siguiente código: internal class Program { private static void Main(string[] args) { var client = new TcpClient(); client.ConnectAsync("localhost", 7105).Wait(); var stream = client.GetStream(); var observable = ...
Manera idiomática de recuperarse de la transmisión en error
Descargo de responsabilidad: es la continuación del anteriorActualización segura para 2 transmisiones dependientes [https://stackoverflow.com/q/27596693/251311] pregunta Cuál es elidiomático ¿Cómo manejar los errores en RxJS (o cualquier ...