/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit/Testing/ReceivedMessageFilterSet.cs
32 строки
765 B
Chris Patterson
Rewrote Testing Received/Consumed/Published/Saga lists to support asynchronous awaits
20 май 2020, 00:53
20 май 2020, 00:53
5197208
Код
Авторство
О чём код?
namespace MassTransit.Testing { public class ReceivedMessageFilterSet : FilterSet<IReceivedMessage> { public ReceivedMessageFilterSet Add<T>() where T : class { static bool Filter(IReceivedMessage element) { return element is IReceivedMessage<T>; } Add(Filter); return this; } public ReceivedMessageFilterSet Add<T>(FilterDelegate<IReceivedMessage<T>> filter) where T : class { bool Filter(IReceivedMessage element) { return element is IReceivedMessage<T> result && filter(result); } Add(Filter); return this; } } }