src/EasyFrameWork/Notification/Queue/EmailQueue.cs

（完整代码） 891B 

/* http://www.zkea.net/ 
 * Copyright (c) ZKEASOFT. All rights reserved. 
 * http://www.zkea.net/licenses */
 

using Easy.Notification;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Channels;
using System.Threading.Tasks;

namespace Easy.Notification.Queue
{
    public class EmailQueue : IEmailQueue
    {
        private Channel<EmailContext> _channel;
        public EmailQueue()
        {
            _channel = Channel.CreateUnbounded<EmailContext>();
        }
        public async Task Send(EmailContext emailContext)
        {
            await _channel.Writer.WriteAsync(emailContext);
        }

        public async Task<EmailContext> Receive(CancellationToken cancellationToken = default)
        {
            return await _channel.Reader.ReadAsync(cancellationToken);
        }
    }
}

24 小时内免费解锁 3 个项目，之后 1 算力/个。 规则说明

AI 解读 AI

登录后可用，每次 10 算力，解读结果公开显示在下面。

还没有人解读过这个文件。