【Unity】MessagePipeの基本的な使い方についてまとめる

using MessagePipe;
using VContainer;
using VContainer.Unity;
public class TestLifetimeScope : LifetimeScope
{
    protected override void Configure(IContainerBuilder builder)
    {
        // int型のメッセージを登録してみる
        var options = builder.RegisterMessagePipe();
        builder.RegisterMessageBroker<int>(options);
        // EntryPoint登録
        builder.RegisterEntryPoint<TestEntryPoint>();
    }
}

using System;
using Cysharp.Threading.Tasks;
using MessagePipe;
using UnityEngine;
using VContainer.Unity;
public class TestEntryPoint : IStartable, IDisposable
{
    private readonly IPublisher<int> _testPublisher;
    private readonly ISubscriber<int> _testSubscriber;
    private IDisposable _disposable;
    public TestEntryPoint(IPublisher<int> testPublisher, ISubscriber<int> testSubscriber)
    {
        _testPublisher = testPublisher;
        _testSubscriber = testSubscriber;
    }
    public void Start()
    {
        // 購読開始
        var d = DisposableBag.CreateBuilder();
        _testSubscriber.Subscribe(x =>
        {
            Debug.Log(x); // とりあえずログ出力
        }).AddTo(d);
        _disposable = d.Build();
        // 試しに発行
        TestPublishAsync();
    }
    public void Dispose()
    {
        // 購読解除
        _disposable?.Dispose();
    }
    private async void TestPublishAsync()
    {
        // 一定間隔で発行する
        _testPublisher.Publish(10);
        await UniTask.Delay(500);
        _testPublisher.Publish(20);
        await UniTask.Delay(500);
        _testPublisher.Publish(30);
    }
}

/// <summary>
/// 攻撃データ
/// </summary>
public class AttackData
{
    /// <summary>
    /// ダメージ量
    /// </summary>
    public int Damage;
}

using MessagePipe;
/// <summary>
/// プレイヤークラス
/// </summary>
public class Player
{
    private readonly IPublisher<AttackData> _onDoAttackEvent;
    public Player(IPublisher<AttackData> onDoAttackEvent)
    {
        _onDoAttackEvent = onDoAttackEvent;
    }
    /// <summary>
    /// 攻撃実行
    /// </summary>
    public void OnAttack(int damage)
    {
        _onDoAttackEvent.Publish(new AttackData()
        {
            Damage = damage,
        });
    }
}

using System;
using MessagePipe;
using UnityEngine;
/// <summary>
/// エネミークラス
/// </summary>
public class Enemy : IDisposable
{
    private readonly ISubscriber<AttackData> _onReceiveAttackEvent;
    private IDisposable _disposable;
    private string _name;
    private int _hp;
    private bool _isDead;
    public Enemy(ISubscriber<AttackData> onReceiveAttackEvent, string name, int hp)
    {
        _onReceiveAttackEvent = onReceiveAttackEvent;
        _name = name;
        _hp = hp;
        _isDead = false;
        OnInitialize();
    }
    /// <summary>
    /// 初期化処理
    /// </summary>
    private void OnInitialize()
    {
        // 攻撃通知イベントの購読開始
        var d = DisposableBag.CreateBuilder();
        _onReceiveAttackEvent.Subscribe(attackData =>
        {
            if (_isDead) return;
            // ダメージを受ける
            _hp -= attackData.Damage;
            Debug.Log($"{_name} は {attackData.Damage} のダメージを受けた");
            // 死亡判定
            if (_hp <= 0)
            {
                _hp = 0;
                _isDead = true;
                Debug.Log($"{_name} は死亡した...");
            }
        }).AddTo(d);
        _disposable = d.Build();
    }
    public void Dispose()
    {
        _disposable?.Dispose();
    }
}

using MessagePipe;
using VContainer;
using VContainer.Unity;
public class BattleLifeTimeScope : LifetimeScope
{
    protected override void Configure(IContainerBuilder builder)
    {
        // 攻撃通知のメッセージを登録
        var options = builder.RegisterMessagePipe();
        builder.RegisterMessageBroker<AttackData>(options);
        // EntryPoint登録
        builder.RegisterEntryPoint<BattleEntryPoint>();
    }
}

using System.Collections.Generic;
using MessagePipe;
using UnityEngine;
using VContainer.Unity;
public class BattleEntryPoint : IStartable, ITickable
{
    private readonly IPublisher<AttackData> _onDoAttackEvent;
    private readonly ISubscriber<AttackData> _onReceiveAttackEvent;
    public BattleEntryPoint(IPublisher<AttackData> onDoAttackEvent, ISubscriber<AttackData> onReceiveAttackEvent)
    {
        _onDoAttackEvent = onDoAttackEvent;
        _onReceiveAttackEvent = onReceiveAttackEvent;
    }
    private Player _player;
    private List<Enemy> _enemies;
    public void Start()
    {
        // プレイヤー生成
        _player = new Player(_onDoAttackEvent);
        // エネミー生成
        _enemies = new List<Enemy>();
        _enemies.Add(new Enemy(_onReceiveAttackEvent, "エレキベア", 200));
        _enemies.Add(new Enemy(_onReceiveAttackEvent, "ゴロヤン", 500));
        _enemies.Add(new Enemy(_onReceiveAttackEvent, "パインバード", 100));
    }
    public void Tick()
    {
        // スペースキー押下で攻撃
        if (Input.GetKeyDown(KeyCode.Space))
        {
            _player.OnAttack(100);
        }
    }
}