Resultados de la búsqueda a petición "system.reactive"
Lea continuamente bytestream de Stream usando TcpClient y Reactive Extensions
Considere el siguiente código: internal class Program { private static void Main(string[] args) { var client = new TcpClient(); client.ConnectAsync("localhost", 7105).Wait(); var stream = client.GetStream(); var observable = ...
Regulación de eventos y métodos de bloqueo
Supongamos que tengo algo como esto: <TextBox Text="{Binding Text, Mode=TwoWay}" />Y algo como esto: public class MyViewModel : INotifyPropertyChanged { public MyViewModel() { // run DoWork() when this.Text ...
Rx I Almacenamiento en búfer observable para suavizar ráfagas de eventos
Tengo una secuencia observable que produce eventos en ráfagas rápidas (es decir: cinco eventos uno tras otro, luego un gran retraso, luego otra ráfaga rápida de eventos, etc.). Quiero suavizar estas ráfagas insertando un breve retraso entre los ...
EventBus / PubSub vs (extensiones reactivas) RX con respecto a la claridad del código en una sola aplicación de subprocesos
Actualmente, estoy usando un EventBus /PubSub [http://en.wikipedia.org/wiki/Publish%E2%80%93subscribe_pattern]arquitectura / patrón con Scala (y JavaFX) para implementar una aplicación simple de organización de notas (algo así como un cliente ...
¿Cómo puedo esperar que todo se haga en una secuencia observable de Rx después de cancelar la suscripción?
Introducción En mi aplicación WPF C # .NET, uso las extensiones reactivas (Rx) para suscribirme a eventos y, a menudo, tengo que volver a cargar algo de la base de datos para obtener los valores que necesito para actualizar la interfaz ...
Extensiones reactivas Búsqueda instantánea para WPF / MVVM
Me gustaría implementar un TextBox donde, a medida que escribe, los resultados aparecen instantáneamente en otro ListBox. He estado buscando ejemplos con Reactive Extensions (Rx), y todos los que encontré usanObservable.FromEventPattern() junto ...
¿Por qué nunca se llama a la devolución de llamada OnError cuando se lanza desde el suscriptor dado?
Por favor, observe la siguiente prueba de unidad: using System; using System.Reactive.Linq; using System.Threading; using System.Threading.Tasks; using Microsoft.VisualStudio.TestTools.UnitTesting; namespace UnitTests { [TestClass] public class ...
Filtrar un Touch.FrameReported IObservable utilizando una condición booleana arbitraria que cambia con el tiempo
He estado jugando con las Extensiones Reactivas (RX) en Windows Phone 7 y estoy muy cerca de una solución que funciona, pero quedé atrapado en un pequeño detalle. Estoy tratando de procesar los eventos táctiles sin procesar ...
¿Cómo espero una respuesta de un sujeto RX sin presentar una condición de carrera?
Tengo un servicio que permite a la persona que llama enviar comandos y recibir respuestas de forma asincrónica. En una aplicación real, estas acciones están bastante desconectadas (alguna acción enviará un comando y las respuestas se procesarán ...
¿Debería IObservable ser preferido sobre los eventos al exponer notificaciones en una biblioteca dirigida a .NET 4+
Tengo una biblioteca .NET que, como parte de un Modelo de Objetos, emitirá notificaciones de ciertas ocurrencias. Me parece que el principalpros deeventosson accesibilidad para principiantes (y simplicidad en ciertos contextos de consumo) con el ...