ReactiveValues

Namespace: Vortex.Core.Extensions.ReactiveValues Сборка: ru.vortex.extensions Платформа: .NET Standard 2.1+

---

Назначение

Реактивные обёртки над простыми типами данных. При изменении значения уведомляют подписчиков.

Возможности:

• Типизированное событие OnUpdate с новым значением
• Нетипизированное событие OnUpdateData (интерфейс IReactiveData)
• Implicit-оператор для чтения без .Value
• Владелец контейнера — только владелец может изменять значение через Set()
• Интерфейс IReactiveData помечен [POCO] — все реализации автоматически сериализуемы через SerializeController

Вне ответственности:

• Потокобезопасность
• Валидация значений
• Потокобезопасная подписка/отписка

---

Зависимости

---

Архитектура

IReactiveData [POCO]                     ← интерфейс: event OnUpdateData
├── ReactiveValue<T> (abstract)          ← одиночное значение
│   ├── IntData                          ← ReactiveValue<int>
│   ├── FloatData                        ← ReactiveValue<float>
│   ├── BoolData                         ← ReactiveValue<bool>
│   ├── StringData                       ← ReactiveValue<string>, ToString()
│   └── EnumData<TEnum>                  ← ReactiveValue<TEnum> where TEnum : Enum
│
└── ReactiveCollection<T> (abstract)     ← реактивный List<T>: Add/Remove/Insert/Sort/...
    └── ListData<T>                      ← конструкторы (пустой / из List<T>)

Компоненты

---

Контракт

API

Гарантии

• Set() вызывает события только при изменении значения (дедупликация через EqualityComparer<T>.Default)
• Set() с неверным владельцем логирует ошибку и не меняет значение
• SetOwner() запрещает повторное назначение — логирует ошибку
• Без владельца (_owner == null) Set() работает без ограничений
• ForceUpdate() вызывает события без проверки на изменение значения
• implicit operator позволяет использовать ReactiveValue<T> везде где ожидается T
• Все наследники конструируются с начальным значением: new IntData(0) или с владельцем: new IntData(0, owner)
• [POCO] на IReactiveData делает все реализации сериализуемыми через SerializeController

Ограничения

• Нет конструктора без параметров — десериализация через FormatterServices.GetUninitializedObject()
• Владелец назначается однократно и не может быть снят
• Не потокобезопасен

---

Использование

Объявление

public class PlayerModel
{
    public IntData Level { get; set; } = new IntData(1);
    public StringData Name { get; set; } = new StringData("Player");
    public BoolData IsAlive { get; set; } = new BoolData(true);
}

Подписка на изменения

var model = new PlayerModel();

// Типизированная подписка
model.Level.OnUpdate += newLevel => Debug.Log($"Level: {newLevel}");

// Нетипизированная подписка (IReactiveData)
model.Level.OnUpdateData += () => Debug.Log("Level changed");

Implicit operator

int level = model.Level;           // implicit operator
string name = model.Name;          // implicit operator
if (model.IsAlive) { /* ... */ }   // implicit operator

Изменение значения

model.Level.Set(5);   // вызовет OnUpdate(5) и OnUpdateData
model.Level.Set(5);   // повторный вызов — значение не изменилось, события НЕ вызываются

Владелец контейнера

// Контроллер назначает себя владельцем
model.Level.SetOwner(this);

// Только владелец может менять значение
model.Level.Set(10, this);    // OK
model.Level.Set(10, other);   // Error: "Trying to change value from outer Object."
model.Level.Set(10);          // Error: owner = null != this

Запирание приватным ключом (рекомендуется)

Передавать this в качестве владельца — допустимо, но протекаемо: ссылка на контроллер обычно публично доступна, и любой код может вызвать data.Set(value, controller), выдавая себя за владельца. Замок теряет смысл.

Чистый паттерн — отдельный приватный ключ внутри контроллера:

public class HealthController
{
    private readonly object _key = new();
    public IntData Hp { get; } = new IntData(100);

    public HealthController()
    {
        Hp.SetOwner(_key);
    }

    public void Damage(int amount)
    {
        Hp.Set(Hp - amount, _key);   // OK
    }
}

// Снаружи:
controller.Hp.Set(0, controller);  // Error — `controller` не ключ
controller.Hp.Set(0);              // Error — null не ключ

_key — private, никем извне не виден, инстанцируется внутри контроллера и нигде не публикуется. Ни рефлексия (по типу object), ни случайная утечка ссылки не дадут постороннему обойти замок.

Тот же подход работает для ReactiveCollection<T> (ListData<T> и т. д.) и для конструкторов с владельцем:

public IntData Hp { get; }

public HealthController()
{
    Hp = new IntData(100, _key);   // владелец сразу из ключа
}

Конструктор с владельцем

// Контейнер с владельцем сразу при создании
var hp = new IntData(100, this);
hp.Set(90, this);    // OK
hp.Set(90, other);   // Error

Принудительное обновление

// Вызвать события без изменения значения
model.Level.ForceUpdate();

Реактивная коллекция

public class InventoryModel
{
    public ListData<ItemId> Items { get; private set; } = new();
}

inventory.Items.OnUpdate += list => RefreshUI(list);   // IReadOnlyList<ItemId>
inventory.Items.OnUpdateData += () => Counter.Refresh(); // нетипизированная нотификация

inventory.Items.Add(itemId);                 // OnUpdate срабатывает
inventory.Items.Remove(missingId);           // не найден → OnUpdate НЕ срабатывает
inventory.Items.SetOwner(this);              // далее только this может мутировать
inventory.Items.Add(itemId, this);           // OK
inventory.Items.Add(itemId, other);          // Error: чужой owner

var snapshot = inventory.Items.GetList();    // IReadOnlyList<ItemId>, доступ только для чтения

Использование с QuestController

// IReactiveData позволяет подписаться на изменения для перепроверки условий квестов
QuestController.SetListener(model.Level, this);

---

Граничные случаи