59 lines
1.6 KiB
C#
59 lines
1.6 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
using UnityEngine;
|
|
using static KCM.StateManagement.Observers.Observer;
|
|
|
|
namespace KCM.StateManagement.Observers
|
|
{
|
|
public class StateObserver
|
|
{
|
|
public static Dictionary<int, IObserver> observers = new Dictionary<int, IObserver>();
|
|
|
|
public static void ClearAll()
|
|
{
|
|
foreach (var observer in observers.Values)
|
|
{
|
|
try
|
|
{
|
|
var component = observer as Component;
|
|
if (component != null)
|
|
UnityEngine.Object.Destroy(component.gameObject);
|
|
}
|
|
catch
|
|
{
|
|
}
|
|
}
|
|
|
|
observers.Clear();
|
|
}
|
|
|
|
public static void RegisterObserver<T>(T instance, string[] monitoredFields, EventHandler<StateUpdateEventArgs> eventHandler = null, EventHandler<StateUpdateEventArgs> sendUpdateHandler = null)
|
|
{
|
|
if (observers.ContainsKey(instance.GetHashCode()))
|
|
return;
|
|
|
|
var observerObject = new GameObject($"{instance.GetHashCode()} {instance.GetType().Name} State Observer");
|
|
|
|
var observer = observerObject.AddComponent<Observer>();
|
|
|
|
|
|
observer.Initialise(instance, monitoredFields, observerObject);
|
|
|
|
|
|
if (eventHandler != null)
|
|
observer.StateUpdated += eventHandler;
|
|
|
|
|
|
if (sendUpdateHandler != null)
|
|
observer.SendUpdate += sendUpdateHandler;
|
|
|
|
|
|
observers.Add(instance.GetHashCode(), observer);
|
|
|
|
}
|
|
}
|
|
}
|