server/src/Core/Services/Implementations/BlockingMailQueueService.cs

using System;
using System.Collections;
using System.Collections.Generic;
using System.Threading.Tasks;
using Bit.Core.Models.Mail;

namespace Bit.Core.Services
{
    public class BlockingMailEnqueuingService : IMailEnqueuingService
    {
        public async Task EnqueueAsync(IMailQueueMessage message, Func<IMailQueueMessage, Task> fallback)
        {
            await fallback(message);
        }

        public async Task EnqueueManyAsync(IEnumerable<IMailQueueMessage> messages, Func<IMailQueueMessage, Task> fallback)
        {
            foreach (var message in messages)
            {
                await fallback(message);
            }
        }
    }
}