namespace Observability.Common
{

    /// <summary>
    /// Extension of the observable objects class,
    /// Allows other threads to trigger binding updates
    /// </summary>
    public partial class MoreObservableObject : ObservableObject
    {

        private static DispatcherQueue Queue { get; set; }
        public static void BindGUIThread(DispatcherQueue queue)
        {
            Queue = queue;
        }
        public static void Update(Action action)
        {
            if (Queue == null)
            {
                action();
                return;
            }
            Queue.TryEnqueue(() => action());
        }
        protected override void OnPropertyChanged(PropertyChangedEventArgs e)
        {
            Update(() => base.OnPropertyChanged(e));
        }
    }

    public class MoreObservableCollection<T> : ObservableCollection<T>
    {
        public new void Add(T item)
        {
            MoreObservableObject.Update(() => base.Add(item));
        }

        public new void Clear()
        {
            MoreObservableObject.Update(() => base.Clear());
        }

        public new void RemoveAt(int index)
        {
            MoreObservableObject.Update(() => {
                if (base.Count > index) base.RemoveAt(index);
            });
        }

    }
}