Til.EventBus 2.0.1

EventBus

一个高效的事件总线

如何使用

< C#
using Til.EventBus;

namespace Til.EventBusTest;

public class Demo {

    [Fact]
    public void staticEventHandleTest() {
        IEventBus eventBus = new EventBus.EventBus(new EventBus.EventBus.EventBusBuilder());
        eventBus.put(typeof(StaticEventHandle));

        eventBus.onEvent(new ParentEvent.ChildEvent());
        Assert.Equal(1, StaticEventHandle.counter);
    }

    [Fact]
    public void eventHandleTest() {
        IEventBus eventBus = new EventBus.EventBus(new EventBus.EventBus.EventBusBuilder());
        EventHandle eventHandle = new EventHandle();
        eventBus.put(eventHandle);

        eventBus.onEvent(new ParentEvent.ChildEvent());
        Assert.Equal(1, eventHandle.counter);
    }

    [Fact]
    public async Task asyncEventHandleTest() {
        IEventBus eventBus = new EventBus.EventBus(new EventBus.EventBus.EventBusBuilder());
        AsyncEventHandle asyncEventHandle = new AsyncEventHandle();
        eventBus.put(asyncEventHandle);

        CancellationTokenSource source = new CancellationTokenSource();
        //所有继承 IAsyncEvent 的事件可以以异步的形式发布
        await eventBus.onEventAsync(new AsyncEvent(source.Token));

        Assert.Equal(1, asyncEventHandle.counter);
    }

    [Fact]
    public async Task groupingAsyncEventHandleTest() {
        IEventBus eventBus = new EventBus.EventBus(new EventBus.EventBus.EventBusBuilder());
        GroupingAsyncEventHandle groupingAsyncEventHandle = new GroupingAsyncEventHandle();
        eventBus.put(groupingAsyncEventHandle);

        CancellationTokenSource source = new CancellationTokenSource();
        await eventBus.onEventAsync(new AsyncEvent.SonAsyncEvent(source.Token));
        await eventBus.onEventAsync(new EmptyGroupSynchronizationEvent(source.Token));
    }

}

public class StaticEventHandle {

    public static int counter;

    /// <summary>
    /// 静态方法
    /// 使用 eventBus.put(typeof(StaticEventHandle)); 注册
    /// </summary>
    [Event]
    public static void onEvent(ParentEvent parentEvent) {
        counter++;
    }

}

public class EventHandle {

    public int counter;

    /// <summary>
    /// 实例方法
    /// 使用 eventBus.put(new EventHandle()); 注册
    /// </summary>
    [Event]
    public void onEvent(ParentEvent parentEvent) {
        counter++;
    }

}

public class AsyncEventHandle {

    public int counter;

    [Event]
    public async Task onEvent(AsyncEvent async) {
        await Task.Delay(100);
        counter++;
    }

}

public class GroupingAsyncEventHandle {

    public int counterA;

    /// <summary>
    /// 同组的将按照优先级从上到下调用
    /// 空组默认并发处理
    /// 其中异常不会传播
    /// </summary>
    [Event(concurrencyGroup = "A", priority = 1)]
    public async Task onEvent_A1(AsyncEvent @event) {
        await Task.Delay(100);
        counterA++;
    }

    [Event(concurrencyGroup = "A", priority = 0)]
    public async Task onEvent_A0(AsyncEvent @event) {
        await Task.Delay(100);
        Assert.Equal(1, counterA);
    }

    /// <summary>
    /// EmptyGroupSynchronizationEvent 指定空组同步
    /// 不需要指定 concurrencyGroup 也能按照优先级调用
    /// </summary>
    /// <param name="event"></param>
    [Event(priority = 1)]
    public async Task onEvent_B1(EmptyGroupSynchronizationEvent @event) {
        await Task.Delay(100);
        counterA++;
    }

    [Event(priority = 0)]
    public async Task onEvent_B0(EmptyGroupSynchronizationEvent @event) {
        await Task.Delay(100);
        Assert.Equal(1, counterA);
    }

}

public class ParentEvent : Event {

    public class ChildEvent : ParentEvent {

    }

}

public class AsyncEvent : Event, IAsyncEvent {

    public CancellationToken token { get; }

    public AsyncEvent(CancellationToken token) {
        this.token = token;
    }

    public class SonAsyncEvent(CancellationToken token) : AsyncEvent(token);

}

public class EmptyGroupSynchronizationEvent : Event, IAsyncEvent {

    public CancellationToken token { get; }

    public EmptyGroupSynchronizationEvent(CancellationToken token) {
        this.token = token;
    }

    public bool isEmptyGroupSynchronization => true;

}