Resultados de la búsqueda a petición "system.reactive"

2 la respuesta

Convierta eventos sin EventArgs usando Observable.FromEvent

Estoy luchando para convertir el siguiente evento en unIObservable: public delegate void _dispSolutionEvents_OpenedEventHandler(); event _dispSolutionEvents_OpenedEventHandler Opened;El evento proviene de una biblioteca, así que no puedo ...

3 la respuesta

RxJs: ejemplo de arrastrar y soltar: agregar mousedragstart

Cómo implementar unmousedragstart Observable usando elEjemplo de arrastrar y soltar RxJs [https://github.com/Reactive-Extensions/RxJS/blob/master/examples/dragndrop/dragndrop.js] . mousedragstart debe emitirse antes de la primeramousedrag ...

1 la respuesta

RxJava: Cómo aplicar operadores condicionalmente a un observable sin romper la cadena

Tengo una cadena de operadores en un RxJava observable. Me gustaría poder aplicar uno de dos operadores dependiendo de un valor booleano sin "romper la cadena". Soy relativamente nuevo en Rx (Java) y siento que probablemente haya una forma más ...

2 la respuesta

RX Scheduler - ¿Qué es?

¿Estoy leyendo sobre RX y totalmente confundido con lo que está destinado el Programador? ¿Alguien puede explicar?

0 la respuesta

¿Hay alguna manera de mantener una colección de "mensajes" de hasta 1 MB y escribir el resultado en el archivo JSON / CSV

Tengo una cola de bloqueo que sigue recibiendo mensajes a través de alguna aplicación, ahora en la aplicación asp.net intenté consumir la cola y escribir la salida en el archivo CSV / JSON. Aquí quiero retener mensajes de hasta 1 MB que se ...

5 la respuesta

¿Cómo cambio la implementación de Rx Builder para corregir la excepción de desbordamiento de pila?

Estoy tratando de encontrar un Rx Builder para usar Reactive Extension dentro de la sintaxis de F # Computation Expression. ¿Cómo lo arreglo para que no explote la pila? Como el ejemplo de Seq a continuación. ¿Y hay algún plan para proporcionar ...

1 la respuesta

¿Cuáles son las extensiones reactivas utilizadas para

Un sitio web MVC 3 con algunas secciones en Silverlight 5 ¿Se puede utilizar Rx en este escenario? Si es así, cómo y qué componentes de la aplicación pueden beneficiarse

3 la respuesta

¿Cuándo usar Observable.FromEventPattern en lugar de Observable.FromEvent?

Tenemos un cliente llamando a una cola de TIBCO EMS y estamos conectando los eventos de esta manera: var msgConsumer = _session.CreateConsumer(responseQueue); var response = Observable.FromEvent<EMSMessageHandler,EMSMessageEventArgs> (h ...

2 la respuesta

Rx para .NET - ¿Qué pasó con Scheduler.Dispatcher?

Estoy tratando de trabajar en el curso de capacitación de Extensiones Rx de Dan Sullivan en PluralSight. Es excelente, pero desafortunadamente Rx parece haber cambiado, aunque el curso solo se publicó hace un mes. La mayoría de los cambios son ...

2 la respuesta

Procesamiento de cola asíncrona con extensiones reactivas

Hay un par de artículos sobre esto, y tengo esto funcionando ... pero quiero saber cómo establecer un número máximo de subprocesos de tareas para mis suscripciones de Observable a la vez. Tengo lo siguiente para paralelizar el almacenamiento ...