Saturday, October 15, 2016

Rx Replay


Hot= publish(), cold=hot replay(), hot connect, cold connect
        private void SetupReplayObservable()
        {
           var HotObservable = Observable.FromEvent(
                    h => _Manager.DataReceived += h,
                    h => _Manager.DataReceived -= h).Publish();
           InfoObservable = HotObservable.Replay();
           HotObservable.Connect();
           InfoObservable.Connect();
        }

No comments:

Post a Comment