/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
tests/MassTransit.Benchmark/ServiceProviderExtensions.cs
28 строк
961 B
Chris Patterson
Adding new benchmark for bus outbox
19 авг 2022, 16:24
19 авг 2022, 16:24
01fa2b7
Код
Авторство
О чём код?
namespace MassTransitBenchmark; 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); } }