Tag: SYSTEM.REACTIVE

Tengo un observable al que necesitaba agregarle una demora entre las notificaciones en caso de que dos notificaciones estén demasiado cerca una de la otra, así que hice lo siguiente. var niceAndSlowObservable = observable .Select(x => Observable.Return(x)) .Delay(1000) .Concat(); Funciona muy bien, no importa qué tan rápido se emitan los . . . Read more

¿Cómo puedo escribir este código en una sola línea? public class RadGridColumnObservable { public RadGridColumnObservable(RadGridView grid, IMessageBus messageBus) { this.grid = grid; this.messageBus = messageBus; } public IDisposable Initialize() { CreateStates(); return Observable .Interval(TimeSpan.FromSeconds(1)) .Subscribe(_ => CheckUp()); } // private readonly RadGridView grid; private readonly IMessageBus messageBus; private readonly List<bool> . . . Read more

Quiero refactorizar el siguiente código: observable.Subscribe(async i => { await Task.Yield(); Console.WriteLine(i); }); para tener un segundo observador, donde los elementos emitidos se retrasan utilizando Task.Yield(); p.ej: var segundoObservable = observable .Delay(e => Task.Yield()); //cómo escribir esto segundoObservable.Subscribe(i => Console.WriteLine(i));