Resultados de la búsqueda a petición "reactive-programming"
¿Cómo solicitar datos secuencialmente en Cycle.js?
Soy nuevo en la programación reactiva y jugando con cycle.js, tratando de implementar a quién seguir el cuadroeste tutorial [https://gist.github.com/staltz/868e7e9bc2a7b8c1f754]. Pero entendí que para una implementación adecuada (y para fines de ...
RxJs: ¿Cómo hacer un bucle en función del estado de lo observable?
Estoy tratando de hacer que RxJs se repita en un Observable en mi transmisión hasta que esté en un cierto estado, luego haga que la transmisión continúe. Específicamente, estoy convirtiendo un bucle sincrónico do / while a RxJs, pero supongo que ...
Falta inexplicable de mejora del rendimiento utilizando RxJava Observables en aplicaciones web
Estoy realizando algunas pruebas para evaluar si hay una ventaja real en el uso de API reactivas basadas en Observables, en lugar de bloquear las tradicionales. Todo el ejemplo esdisponible en ...
Creación dinámica de pestañas con trazados brillantes sin volver a crear pestañas existentes
Me gustaría crear pestañas dinámicas, donde cada vez que el usuario haga clic en un botón, se creará una nueva pestaña. Cada pestaña tiene el mismo contenido, con una variedad de widgets que el usuario puede usar para seleccionar qué conjuntos de ...
Llamar a setState en render no es evitable
Reaccionar documento afirma que elrender la función debe serpurolo que significa que no debería usarthis.setState en él. Sin embargo, creo que cuando el estado depende de 'remoto', es decir, resultado de una llamada ajax. La única ...
Cuándo cancelar una suscripción
Tengo una pregunta sobre cómo cancelar la suscripción de un observable. Tengo dos códigos y no estoy seguro de cuál es mejor. Ejemplo 1 -> Darse de baja del suscriptor una vez que la transmisión haya finalizado: Subscriber<String> subscriber = ...
¿Cómo usar Observable.fromCallable () con una excepción marcada?
Observable.fromCallable() es ideal para convertir una sola función en un Observable. Pero, ¿cómo maneja las excepciones marcadas que podría generar la función? La mayoría de los ejemplos que he visto usan lambdas y "simplemente funcionan". ¿Pero ...
Es RxJava una buena opción para ramificar flujos de trabajo?
Estoy usando RxJava para procesar algunas notificaciones que extraemos de una cola. RxJava parecía funcionar bien con un flujo de trabajo simple, ahora con nuevos requisitos, el flujo está creciendo en complejidad con más ramas (vea la imagen a ...
tap () no se activa en RXJS Pipe
Tengo que hacer lo mismo, aunque prefiero el primero. Pero el primer enfoque no parece funcionar. (eltap() no se activa) // does not work this.actions$.pipe( ofType(LayoutActions.Types.CHANGE_THEME), takeUntil(this.destroyed$), tap(() => { ...
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 ...