/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
tests/MassTransit.Tests/ServiceProviderExtensions.cs
28 строк
958 B
Chris Patterson
Fixed #5712 - Moved bus transport configuration check to the bus depot to throw an exception when trying to start the bus when no bus has been configured.
07 дек 2024, 02:37
07 дек 2024, 02:37
2a2a0c7
Код
Авторство
О чём код?
namespace MassTransit.Tests; using System; using System.Linq; using System.Threading; using System.Threading.Tasks; using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.Hosting; public static class ServiceProviderExtensions { public static async Task StartHostedServices(this IServiceProvider provider, CancellationToken cancellationToken = default) { IHostedService[] services = provider.GetServices<IHostedService>().ToArray(); foreach (var service in services) await service.StartAsync(cancellationToken).ConfigureAwait(false); } public static async Task StopHostedServices(this IServiceProvider provider, CancellationToken cancellationToken = default) { IHostedService[] services = provider.GetServices<IHostedService>().ToArray(); foreach (var service in services.Reverse()) await service.StopAsync(cancellationToken).ConfigureAwait(false); } }