105040 Add 异步发布事件接口
This commit is contained in:
parent
5ff1390e60
commit
8931360620
|
|
@ -6,7 +6,7 @@
|
||||||
string EventName { get; }
|
string EventName { get; }
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 时间处理,返回是否处理成功
|
/// 事件处理,返回是否处理成功
|
||||||
/// </summary>
|
/// </summary>
|
||||||
/// <param name="data"></param>
|
/// <param name="data"></param>
|
||||||
/// <returns></returns>
|
/// <returns></returns>
|
||||||
|
|
|
||||||
|
|
@ -37,7 +37,7 @@ namespace LFlow.InternalEventBus
|
||||||
/// <param name="eventName"></param>
|
/// <param name="eventName"></param>
|
||||||
/// <param name="data"></param>
|
/// <param name="data"></param>
|
||||||
/// <returns></returns>
|
/// <returns></returns>
|
||||||
public static async Task Publish(string eventName, object data)
|
public static async void Publish(string eventName, object data)
|
||||||
{
|
{
|
||||||
if (_eventSubscriberDict.ContainsKey(eventName))
|
if (_eventSubscriberDict.ContainsKey(eventName))
|
||||||
{
|
{
|
||||||
|
|
@ -51,5 +51,18 @@ namespace LFlow.InternalEventBus
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
/// <summary>
|
||||||
|
/// 发布事件
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="eventName"></param>
|
||||||
|
/// <param name="data"></param>
|
||||||
|
/// <returns></returns>
|
||||||
|
public static async Task PublishAsync(string eventName, object data)
|
||||||
|
{
|
||||||
|
Task.Factory.StartNew(() => Publish(eventName, data));
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue