mirror of
https://github.com/unity-atoms/unity-atoms.git
synced 2025-01-23 16:48:23 -05:00
79 lines
2.2 KiB
C#
79 lines
2.2 KiB
C#
|
using System;
|
||
|
using System.Collections.Generic;
|
||
|
using UnityEngine;
|
||
|
|
||
|
namespace UnityAtoms
|
||
|
{
|
||
|
public class ObservableEvent<T> : IObservable<T>
|
||
|
{
|
||
|
private Action<Action<T>> _unregister;
|
||
|
private List<IObserver<T>> _observers = new List<IObserver<T>>();
|
||
|
|
||
|
public ObservableEvent(Action<Action<T>> register, Action<Action<T>> unregister)
|
||
|
{
|
||
|
register(NotifyObservers);
|
||
|
_unregister = unregister;
|
||
|
}
|
||
|
|
||
|
~ObservableEvent()
|
||
|
{
|
||
|
if (_unregister != null)
|
||
|
{
|
||
|
_unregister(NotifyObservers);
|
||
|
}
|
||
|
}
|
||
|
|
||
|
public IDisposable Subscribe(IObserver<T> observer)
|
||
|
{
|
||
|
if (!_observers.Contains(observer))
|
||
|
_observers.Add(observer);
|
||
|
return new ObservableUnsubscriber<T>(_observers, observer);
|
||
|
}
|
||
|
|
||
|
private void NotifyObservers(T value)
|
||
|
{
|
||
|
for (int i = 0; _observers != null && i < _observers.Count; ++i)
|
||
|
{
|
||
|
_observers[i].OnNext(value);
|
||
|
}
|
||
|
}
|
||
|
}
|
||
|
|
||
|
public class ObservableEvent<T1, T2, M> : IObservable<M>
|
||
|
{
|
||
|
private Action<Action<T1, T2>> _unregister;
|
||
|
private List<IObserver<M>> _observers = new List<IObserver<M>>();
|
||
|
private Func<T1, T2, M> _createCombinedModel;
|
||
|
|
||
|
public ObservableEvent(Action<Action<T1, T2>> register, Action<Action<T1, T2>> unregister, Func<T1, T2, M> createCombinedModel)
|
||
|
{
|
||
|
register(NotifyObservers);
|
||
|
_unregister = unregister;
|
||
|
_createCombinedModel = createCombinedModel;
|
||
|
}
|
||
|
|
||
|
~ObservableEvent()
|
||
|
{
|
||
|
if (_unregister != null)
|
||
|
{
|
||
|
_unregister(NotifyObservers);
|
||
|
}
|
||
|
}
|
||
|
|
||
|
public IDisposable Subscribe(IObserver<M> observer)
|
||
|
{
|
||
|
if (!_observers.Contains(observer))
|
||
|
_observers.Add(observer);
|
||
|
return new ObservableUnsubscriber<M>(_observers, observer);
|
||
|
}
|
||
|
|
||
|
private void NotifyObservers(T1 value1, T2 value2)
|
||
|
{
|
||
|
for (int i = 0; _observers != null && i < _observers.Count; ++i)
|
||
|
{
|
||
|
_observers[i].OnNext(_createCombinedModel(value1, value2));
|
||
|
}
|
||
|
}
|
||
|
}
|
||
|
}
|