Resultados de la búsqueda a petición "reactive-programming"
¿Cómo hacer llamadas observables recursivas en RxJava?
Soy bastante nuevo enRxJava [https://github.com/ReactiveX/RxJava](y paradigma reactivo en general), así que tengan paciencia conmigo. Supongamos que tengo estoNews y esta anidadaComment estructura de datos: public class News { public int id; ...
RxJS: división de un resultado de matriz de Observable.fromPromise
Estoy usando RxJS aquí y parece que no puedo superar estoaparentemente Problema simple. rx.Observable .from([1,2,3,54,3,22,323,23,11,2]) .distinct() .subscribe(function next (x) { console.log('Next'); console.log(x); }, function error (x) ...
RxJava- ¿Es cache () lo mismo que replay ()?
Me preguntaba si había uncache() operador que podría almacenar en caché x número de emisiones pero también expirarlas después de un intervalo de tiempo especificado (por ejemplo, 1 minuto). Estaba buscando algo como ...
Cambiar entre diseños de forma reactiva con brillante
¿Cómo puedo cambiar entre diseños de página en Shiny en respuesta a la entrada del usuario? Por ejemplo, me gustaría cambiar entre un diseño de barra lateral a un diseño de panel de pozo para que los gráficos puedan abarcar toda la página. Lo ...
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 ...
Brillante: ¿cuál es la diferencia entre observeEvent y eventReactive?
Leí la documentación de Shiny sobre programación reactiva algunas veces, pero no puedo entender la diferencia entreobserveEvent yeventReactive. La documentación dice: Use observeEvent siempre que desee realizar una acción en respuesta a un ...
Streaming en slick / scala
Estoy viendo la transmisión scala / slick, y estoy tratando de entender cómo funciona. Aquí está mi código de prueba val bigdata = TableQuery[BigData] val x = db.stream(bigdata.result.transactionally.withStatementParameters(fetchSize ...
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 ...
el observable de rxjs no se completa cuando se produce un error
Cuando creo un observable desde cero, y tengo el error del observador, luego completo, la parte completa de la suscripción nunca se invoca. var observer = Rx.Observable.create(function(observer){ observer.onError(new Error('no!')); ...