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