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));
Estoy usando System.Reactive y no sé cuál elegir: ¿EventHandlers o Subjects? ¿Cuál es la diferencia entre ellos? var client = WebSocketClient.Create(uri); // Subject client.OnConnected .Subscribe(_ => { Log.Information($”Socket {client.Id} connected”); }) .DisposeWith(disposable); // EventHandler Observable .FromEventPattern(h => client.Connected += h, h => client.Connected -= h) .Select(_ => Unit.Default) .Subscribe(_ => . . . Read more
Tengo una cantidad desconocida de suscripciones que me gustaría desechar de una sola vez, porque podrían ser muchas. ¿Hay algún mecanismo para desecharlos todos a la vez usando System.Reactive? ¿Quizás envolverlos en Observable.Using(() => Disposable.Create… funcionaría? Aquí está lo que realmente son estas suscripciones. public class BinanceClientStreams { internal readonly . . . Read more