12 references to DistributedApplicationEventSubscription
Aspire.Hosting (12)
Eventing\DistributedApplicationEventing.cs (9)
14
private readonly ConcurrentDictionary<Type, List<
DistributedApplicationEventSubscription
>> _eventSubscriptionListLookup = new();
15
private readonly ConcurrentDictionary<
DistributedApplicationEventSubscription
, Type> _subscriptionEventTypeLookup = new();
26
foreach (
var
subscription in subscriptions.ToArray())
35
public
DistributedApplicationEventSubscription
Subscribe<T>(Func<T, CancellationToken, Task> callback) where T : IDistributedApplicationEvent
37
var
subscription = new DistributedApplicationEventSubscription(async (@event, ct) =>
49
if (!_eventSubscriptionListLookup.TryAdd(typeof(T), new List<
DistributedApplicationEventSubscription
> { subscription }))
65
public
DistributedApplicationEventSubscription
Subscribe<T>(IResource resource, Func<T, CancellationToken, Task> callback) where T : IDistributedApplicationResourceEvent
78
/// <inheritdoc cref="IDistributedApplicationEventing.Unsubscribe(
DistributedApplicationEventSubscription
)" />
80
public void Unsubscribe(
DistributedApplicationEventSubscription
subscription)
Eventing\IDistributedApplicationEventing.cs (3)
21
DistributedApplicationEventSubscription
Subscribe<T>(Func<T, CancellationToken, Task> callback) where T : IDistributedApplicationEvent;
31
DistributedApplicationEventSubscription
Subscribe<T>(IResource resource, Func<T, CancellationToken, Task> callback) where T : IDistributedApplicationResourceEvent;
38
void Unsubscribe(
DistributedApplicationEventSubscription
subscription);