1 type derived from DistributedApplicationEventSubscription
Aspire.Hosting (1)
Eventing\DistributedApplicationEventSubscription.cs (1)
26: DistributedApplicationEventSubscription((@event, cancellationToken) => callback((IDistributedApplicationResourceEvent)@event, cancellationToken))
1 instantiation of DistributedApplicationEventSubscription
Aspire.Hosting (1)
Eventing\DistributedApplicationEventing.cs (1)
79var subscription = new DistributedApplicationEventSubscription(async (@event, ct) =>
17 references to DistributedApplicationEventSubscription
Aspire.Hosting (17)
Ats\AtsTypeMappings.cs (1)
54[assembly: AspireExport(typeof(DistributedApplicationEventSubscription))]
Ats\BuilderExports.cs (2)
108public static DistributedApplicationEventSubscription SubscribeBeforeStart( 129public static DistributedApplicationEventSubscription SubscribeAfterResourcesCreated(
Eventing\DistributedApplicationEventing.cs (11)
12private readonly ConcurrentDictionary<Type, List<DistributedApplicationEventSubscription>> _eventSubscriptionListLookup = new(); 13private readonly ConcurrentDictionary<DistributedApplicationEventSubscription, Type> _subscriptionEventTypeLookup = new(); 31foreach (var subscription in subscriptions.ToArray()) 58foreach (var subscription in subscriptions.ToArray()) 67foreach (var subscription in subscriptions.ToArray()) 77public DistributedApplicationEventSubscription Subscribe<T>(Func<T, CancellationToken, Task> callback) where T : IDistributedApplicationEvent 79var subscription = new DistributedApplicationEventSubscription(async (@event, ct) => 91if (!_eventSubscriptionListLookup.TryAdd(typeof(T), new List<DistributedApplicationEventSubscription> { subscription })) 106public DistributedApplicationEventSubscription Subscribe<T>(IResource resource, Func<T, CancellationToken, Task> callback) where T : IDistributedApplicationResourceEvent 119/// <inheritdoc cref="IDistributedApplicationEventing.Unsubscribe(DistributedApplicationEventSubscription)" /> 120public void Unsubscribe(DistributedApplicationEventSubscription subscription)
Eventing\IDistributedApplicationEventing.cs (3)
20DistributedApplicationEventSubscription Subscribe<T>(Func<T, CancellationToken, Task> callback) where T : IDistributedApplicationEvent; 29DistributedApplicationEventSubscription Subscribe<T>(IResource resource, Func<T, CancellationToken, Task> callback) where T : IDistributedApplicationResourceEvent; 35void Unsubscribe(DistributedApplicationEventSubscription subscription);