Util/test/Util.Events.Tests/Local/EventBusTest.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 EventBusTest : TestBase {
        /// <summary>
        /// 事件总线
        /// </summary>
        private readonly IEventBus _eventBus;

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

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

        /// <summary>
        /// 测试发布事件 - 测试排序 - 未设置序号
        /// </summary>
        [Fact]
        public async Task TestPublishAsync_Order_1() {
            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 );
        }
    }
}