using System;

using System.Collections.Generic;

using System.Reactive.Disposables;

using System.Reactive.Linq;

using System.Reactive.Subjects;

using System.Threading.Tasks;

using Microsoft.Reactive.Testing;

​

public class Program

{

    public void Main()

    {

        InitDeviceChangeRequestSubscription();

        HandleIncrease();

        HandleIncrease();

        HandleIncrease();

        OnBack();

    }

​

    private void OnBack()

    {

        OnNavigateBackSubscription.Dispose();

        //OnNavigateBackSubscription

        Console.WriteLine("OnBack");

    }

​

    private void SimulateDelay(int secs)

    {

        Task.Delay(TimeSpan.FromSeconds(secs)).Wait(TimeSpan.FromSeconds(secs));

    }

​

    private void InitDeviceChangeRequestSubscription()

    {

        DeviceChangeRequestSubject = new Subject<DeviceStateChangeRequestedRxEvent>();

        InitializeDeviceChangeRequestSubscription(DeviceChangeRequestSubject, (rxEvent) => HandleNextThrottledDeviceChangeRequest(rxEvent));

    }

​

    private void InitializeDeviceChangeRequestSubscription(IObservable<DeviceStateChangeRequestedRxEvent> subject, Action<DeviceStateChangeRequestedRxEvent> onNextAction)

    {

        //var bufferedObservable = subject.Publish(a => a.Buffer(500).Throttle(TimeSpan.FromSeconds(3)));

        //DeviceChangeRequestSubscription = bufferedObservable.Subscribe(onNextAction);//..Subscribe(item => HandleNextThrottledDeviceChangeRequest(item[item.Count-1]));.

        var throttledObservable = subject.Throttle(TimeSpan.FromSeconds(3));

        DeviceChangeRequestSubscription = throttledObservable.Subscribe(onNextAction);

    }

​

    internal void HandleNextThrottledDeviceChangeRequest(DeviceStateChangeRequestedRxEvent e)

    {

        Console.WriteLine(e.State);

        Console.WriteLine(_setPoint);

    }

​

    internal IDisposable DeviceChangeRequestSubscription

    {

        get;

        private set;

    }

​

    internal IDisposable OnNavigateBackSubscription

    {

        get;

        private set;

    }

​

    internal Subject<DeviceStateChangeRequestedRxEvent> DeviceChangeRequestSubject;

    private int _setPoint = 0;

    private void HandleDecrease()

    {

        _setPoint += 1;

        //OnNavigateBackSubscription = DeviceChangeRequestSubject.Subscribe((rxEvent) => HandleNextThrottledDeviceChangeRequest(new DeviceStateChangeRequestedRxEvent("decrease")));//.Subscribe((rxEvent) => HandleNextThrottledDeviceChangeRequest(new DeviceStateChangeRequestedRxEvent("decrease")));

        DeviceChangeRequestSubject.OnNext(new DeviceStateChangeRequestedRxEvent("decrease"));

    }

​

    private void HandleIncrease()

    {

        _setPoint += 1;

        if(OnNavigateBackSubscription != null)

            OnNavigateBackSubscription.Dispose();

        OnNavigateBackSubscription = DeviceChangeRequestSubject.Subscribe();

        DeviceChangeRequestSubject.OnNext(new DeviceStateChangeRequestedRxEvent("increase"));

    }

​

    public class DeviceStateChangeRequestedRxEvent

    {

        public string State

        {

            get;

            private set;

        }

​

        public DeviceStateChangeRequestedRxEvent(string s)

        {

            State = s;

        }

    }

}