Resultados de la búsqueda a petición "reactive-programming"
Secuencia de solicitudes combinadas de RxJava
El problemaTengo dos Apis. Api 1 me da una lista de elementos y Api 2 me da información más detallada para cada uno de los elementos que obtuve de Api 1. La forma en que lo resolví hasta ahora resulta en un mal rendimiento. La preguntaSolución ...
Cómo restringir la concurrencia de la manera correcta en Rx.NET
Observe el siguiente fragmento de código: var result = await GetSource(1000).SelectMany(s => getResultAsync(s).ToObservable()).ToList();El problema con este código es quegetResultAsync se ejecuta al mismo tiempo sin restricciones. Lo que podría ...
Observación de RxJava en subproceso de llamada / suscripción
Tengo algunos problemas para entender cómo funciona subscribeOn / observeOn en RxJava. He creado una aplicación simple con observables que emite nombres de planetas del sistema solar, hace algunos mapas y filtra e imprime resultados. Según tengo ...
Luchando con FRP
He leído sobre FRP y estaba muy emocionado. Se ve muy bien, por lo que puede escribir más código de alto nivel, y todo es más componible, etc. Luego traté de reescribir mi propio pequeño juego con unos pocos cientos de sloc desde JS hasta ...
¿Slick 3.0 es reactivo / asíncrono en el nivel del controlador de la base de datos? ¿Para qué bases de datos?
Históricamente, Slick se ha basado en controladores JDBC, que bloquean internamente la espera de E / S de socket en respuesta a consultas. Cada llamada de base de datos pendiente requiere un subproceso para bloquear en un socket; por lo tanto, no ...
Gestionar solicitudes idénticas con RxJava
Suponga que tengo un buscador que recupera una imagen de un enlace dado en un hilo separado. La imagen se almacenará en la memoria caché. Una vez que la imagen ya se almacena en caché, el buscador no volverá a buscar el enlace. El buscador es ...
¿Cómo implementar observeLatestOn en RxJava (RxScala)?
Estoy tratando de implementar elObserveLatestOn [https://social.msdn.microsoft.com/Forums/en-US/bbcc1af9-64b4-456b-9038-a540cb5f5de5/how-do-i-ignore-allexceptthelatest-value-when-my-subscribe-method-is-running?forum=rx>] operador en RxJava (en ...
C # .NET Rx- ¿Dónde está System.Reactive?
Tengo un fondo intensivo de Java, así que perdóname si estoy pasando por alto algo obvio en C #, pero mi investigación no me lleva a ninguna parte. Estoy tratando de usar la biblioteca reactiva Rx .NET. El compilador no se queja delIObservable ...
Cadena de dos observables de actualización con RxJava
Quiero ejecutar 2 llamadas de red una tras otra. Ambas llamadas de red devuelven Observable. La segunda llamada usa datos del resultado exitoso de la primera llamada, el método en el resultado exitoso de la segunda llamada usa datos ...
Cómo cancelar la tarea con retrofit y rxjava
Tengo descanso api. @Get("/serveraction") public Observable<String> myRequest(@Query("Data") String data);Lo sé, okhttp tiene una funcionalidad de cancelación (por objeto de solicitud, por etiqueta), pero no sé cómo usarlo con retrofit y rxjava. ...