Util/test/Util.Events.Tests/Local/EventBusExtensionsTest.cs

using System.Collections.Generic;
using System.Threading.Tasks;
using Util.Events.Tests.Infrastructure;
using Util.Events.Tests.Samples;
using Xunit;

namespace Util.Events.Tests.Local {
    /// <summary>
    /// 本地事件总线扩展测试
    /// </summary>
    public class EventBusExtensionsTest : TestBase {
        /// <summary>
        /// 本地事件总线
        /// </summary>
        private readonly ILocalEventBus _eventBus;

        /// <summary>
        /// 测试初始化
        /// </summary>
        public EventBusExtensionsTest() {
            _eventBus = GetService<ILocalEventBus>();
        }

        /// <summary>
        /// 测试发布事件集合
        /// </summary>
        [Fact]
        public async Task TestPublishAsync() {
            var event1 = new EventSample { Value = "a" };
            var event2 = new EventSample2();
            var event3 = new EventSample3();
            var events = new List<IEvent> { event1, event2, event3 };
            await _eventBus.PublishAsync( events );
            Assert.Equal( "1:a", event1.Result );
            Assert.Equal( "23", event2.Result );
            Assert.Equal( "54", event3.Result );
        }
    }
}