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

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 LocalEventBusTest : TestBase {
        /// <summary>
        /// 本地事件总线
        /// </summary>
        private readonly ILocalEventBus _eventBus;

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

        /// <summary>
        /// 测试发布事件 - 传入事件参数是具体事件类型
        /// </summary>
        [Fact]
        public async Task TestPublishAsync() {
            var @event = new EventSample { Value = "a" };
            await _eventBus.PublishAsync( @event );
            Assert.Equal( "1:a", @event.Result );
        }

        /// <summary>
        /// 测试发布事件 - 传入事件参数是IEvent接口
        /// </summary>
        [Fact]
        public async Task TestPublishAsync_2() {
            IEvent @event = new EventSample { Value = "a" };
            await _eventBus.PublishAsync( @event );
            Assert.Equal( "1:a", ((EventSample)@event).Result );
        }

        /// <summary>
        /// 测试发布事件 - 测试排序 - 未设置序号
        /// </summary>
        [Fact]
        public async Task TestPublishAsync_Order() {
            var @event = new EventSample2();
            await _eventBus.PublishAsync( @event );
            Assert.Equal( "23", @event.Result );
        }

        /// <summary>
        /// 测试发布事件 - 测试排序 - 设置序号
        /// </summary>
        [Fact]
        public async Task TestPublishAsync_Order_2() {
            var @event = new EventSample3();
            await _eventBus.PublishAsync( @event );
            Assert.Equal( "54", @event.Result );
        }

        /// <summary>
        /// 测试发布事件 - 测试排序 - 设置序号 - 传入事件参数是IEvent接口
        /// </summary>
        [Fact]
        public async Task TestPublishAsync_Order_3() {
            IEvent @event = new EventSample3();
            await _eventBus.PublishAsync( @event );
            Assert.Equal( "54", ( (EventSample3)@event ).Result );
        }
    }
}