Modules/Framework/Gardener.EventBus/EventBusService.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

// -----------------------------------------------------------------------------
// 园丁,是个很简单的管理系统
//  gitee:https://gitee.com/hgflydream/Gardener 
//  issues:https://gitee.com/hgflydream/Gardener/issues 
// -----------------------------------------------------------------------------

using Furion.EventBus;
using System;
using System.Threading;
using System.Threading.Tasks;

namespace Gardener.EventBus
{
    /// <summary>
    /// 事件发送服务
    /// </summary>
    public class EventBusService : IEventBus
    {
        private readonly IEventPublisher eventPublisher;

        public EventBusService(IEventPublisher eventPublisher)
        {
            this.eventPublisher = eventPublisher;
        }
        /// <summary>
        /// 发布消息
        /// </summary>
        /// <param name="e"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        public Task PublishAsync(EventBase e, CancellationToken? cancellationToken = null)
        {
            EventSource<EventBase> eventSource = new EventSource<EventBase>(e.EventType.ToString() + e.EventGroup);
            eventSource.Body = e;
            if (cancellationToken.HasValue)
            {
                eventSource.CancellationToken = cancellationToken.Value;
            }
            return eventPublisher.PublishAsync(eventSource);
        }

        /// <summary>
        /// 发布消息
        /// </summary>
        /// <param name="e"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        public void Publish(EventBase e, CancellationToken? cancellationToken = null)
        {
            PublishAsync(e, cancellationToken);
        }

        /// <summary>
        /// 订阅
        /// </summary>
        /// <typeparam name="TEvent"></typeparam>
        /// <param name="callBack"></param>
        /// <returns></returns>
        /// <exception cref="NotImplementedException"></exception>
        public Subscriber Subscribe<TEvent>(Func<TEvent, Task> callBack) where TEvent : EventBase