Resultados de la búsqueda a petición "reactive-programming"
¿Scala ofrece IO sin bloqueo asíncrono cuando trabaja con archivos?
Estoy usando scala 2.10 y me pregunto si hay algún paquete que tenga IO asíncrono cuando trabajo con archivos. Hice un poco de búsqueda sobre este tema, pero encontré ejemplos como los siguientes val file = new File(canonicalFilename) val bw = ...
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 ...
¿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. ...
RxJS: ¿Cómo actualizaría "manualmente" un Observable?
Creo que debo estar malentendiendo algo fundamental, porque en mi opinión este debería ser el caso más básico para un observable, pero durante mi vida no puedo encontrar la manera de hacerlo a partir de los documentos. Básicamente, quiero poder ...
¿Cómo crear un búfer RxJS que agrupe elementos en NodeJS pero que no dependa del intervalo de ejecución permanente?
Estoy capturando eventos desde una aplicación usandoRx.Observable.fromEvent en un NodeJS. Estos se envían a otro servidor mediante solicitud ( https://www.npmjs.com/package/request [https://www.npmjs.com/package/request]) Para evitar una carga de ...
Sondeo de bases de datos con extensiones reactivas
Tengo que consultar una base de datos de manera oportuna para conocer el estado de un sistema heredado. He pensado en ajustar la consulta alrededor de unObservable, pero no sé la forma correcta de hacerlo. Básicamente, será la misma consulta ...