Resultados de la búsqueda a petición "system.reactive"
Extensiones reactivas Suscríbete llamadas en espera
Quiero realizar una llamada asincrónica basada en cadaevento planteado por un observable de extensiones reactivas. También estoy tratando de mantener todo sincronizado ya que quiero que la llamada asincrónica termine antes de que se maneje el ...
Con MongoDB, ¿es posible recibir notificaciones de ediciones de terceros a través de .NET Reactive Extensions (RX)?
Me pregunto si alguien sabe si es posible recibir notificaciones en vivo de cualquier edición en una base de datos MongoDB a través de Extensiones Reactivas (RX) en C #. Esto significaría que cualquier tercero podría editar la base de datos ...
Buen ejemplo de uso de extensiones reactivas [cerrado]
Entiendo los conceptos básicos de Rx. ¿Dónde estoy luchando es cómo usarías esto más allá de los ejemplos académicos? ¿Cuáles son algunos escenarios comunes y simples del mundo real donde Rx es una solución mucho mejor que la que tenemos hoy en .NET?
¿Cómo crear una transmisión Rx (RxJS) que se puede cambiar entre un solo artículo y el modo por lotes?
Tengo una transmisión Rx que es una fuente de cambio saliente de un componente en particular. Ocasionalmente quiero poder ingresar unpor lotes en la secuencia para que los elementos pasen aEn el siguiente se acumulan y se transmiten solo cuando ...
Obtenga el elemento anterior en IObservable sin volver a evaluar la secuencia
En unIObservable secuencia (en Extensiones reactivas para .NET), me gustaría obtener el valor de los elementos anteriores y actuales para poder compararlos. Encontré un ejemplo en línea similar al siguiente que realiza la ...
Cómo usar el nuevo BufferWithTimeOrCount en Rx que devuelve IObservable <IObservable <T>> en lugar de IObservable <IList <T>>
En Windows Phone 7 hay una nueva versión delBufferWithTimeOrCountMétodo de extensión para IObservable que devuelve una "secuencia de secuencias" en lugar de la "secuencia de listas" anterior. Tengo dificultades para intentar usar los métodos ...
¿Cómo puedo borrar el búfer en un ReplaySubject?
¿Cómo puedo borrar el búfer en un ReplaySubject? Periódicamente necesito borrar el búfer (como un evento de final del día en mi caso) para evitar que ReplaySubject crezca continuamente y eventualmente se coma toda la memoria. Idealmente, quiero ...
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 ...
RX: ráfagas de elementos de grupo / lote en una secuencia observable
Tengo una secuencia observable. Cuando se inserta el primer elemento,Me gustaría iniciar un temporizador y agrupar elementos insertados posteriormente durante el intervalo de tiempo del temporizador. Entonces, el temporizador no volvería ...
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 ...