Resultados de la búsqueda a petición "system.reactive"
Tubería reactiva: ¿cómo controlar el paralelismo?
Estoy construyendo una tubería de procesamiento sencilla en la que un elemento se obtiene como entrada, está siendo operado por múltiples procesadores de manera secuencial y finalmente se emite. La imagen a continuación describe la arquitectura ...
Rx como combinar comando con otro observable
Tengo varios comandos reactivos, así como algunos observables que contienen información, y estoy tratando de hacer algo como: _navigate = ReactiveCommand.Create(CanNavigate); _navigate.CombineLatest(navigationTarget, (_, tgt) => tgt) ...
¿Usa las extensiones reactivas (Rx) para la programación de sockets?
¿Cuál es la forma más sucinta de escribir elGetMessages funcionar con Rx: static void Main() { Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); var messages = GetMessages(socket, IPAddress.Loopback, ...
¿Cuál es una buena manera de ejecutar tareas periódicas en C # usando Rx con una sola restricción de ejecución concurrente?
Quiero ejecutar tareas periódicas con una restricción de que a lo sumo solo se ejecuta una ejecución de un método en un momento dado. Estaba experimentando con Rx, pero no estoy seguro de cómo imponer como máximo una vez la restricción de ...
Observable desde tareas encadenadas
Estoy tratando de crear un Observable donde cada elemento se produce a través de una tarea asincrónica. El siguiente elemento debe producirse mediante una llamada asíncrona en el resultado del elemento anterior (co-recursión). En el lenguaje ...
IObservable vs eventos simples o ¿Por qué debo usar IObservable?
Microsoft presentó elIObservable<T> interfaz [http://msdn.microsoft.com/en-us/library/dd990377.aspx]al BCL con .NET Framework 4, y pensé, "¡Genial, finalmente, debo usarlo!" Así que busqué profundamente y leí publicaciones y documentación e ...
¿Se pueden usar las extensiones reactivas (Rx) a través de los límites del proceso o de la máquina?
Recuerda vagamente haber visto algunas discusiones sobre esto hace bastante tiempo, pero no he vuelto a saber nada desde entonces. Entonces, ¿básicamente puede suscribirse a un IObservable en una máquina remota?
¿Cómo comparto un observable con publicar y conectar?
Tengo un flujo de datos observable al que estoy aplicando operaciones, dividiéndome en dos flujos separados, aplicando más operaciones (distintas) a cada uno de los dos flujos, y fusionándolos nuevamente. Estoy tratando de compartir lo observable ...
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 ...
Angular2 Observable.forkJoin de variables observables - ReferenceError: Observable no está definido
Me gustaría pedirle ayuda. Omití el código que supongo que no es importante. Imaginemos un archivo TS que contiene llamadas de servicio: // archivo: someService.ts @Injectable() export class SomeService { method1(){ var observable ...