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)
127var subscription = new DistributedApplicationEventSubscription(async (@event, ct) =>
24 references to DistributedApplicationEventSubscription
Aspire.Hosting (24)
Ats\AtsTypeMappings.cs (1)
74[assembly: AspireExport(typeof(DistributedApplicationEventSubscription))]
Ats\BuilderExports.cs (4)
202public static DistributedApplicationEventSubscription SubscribeBeforeStart( 226public static DistributedApplicationEventSubscription SubscribeBeforePublish( 250public static DistributedApplicationEventSubscription SubscribeAfterPublish( 274public static DistributedApplicationEventSubscription SubscribeAfterResourcesCreated(
Ats\EventingExports.cs (4)
168public static DistributedApplicationEventSubscription OnBeforeStart(this EventingSubscriberRegistrationContext context, Func<BeforeStartEvent, Task> callback) 183public static DistributedApplicationEventSubscription OnBeforePublish(this EventingSubscriberRegistrationContext context, Func<BeforePublishEvent, Task> callback) 198public static DistributedApplicationEventSubscription OnAfterPublish(this EventingSubscriberRegistrationContext context, Func<AfterPublishEvent, Task> callback) 213public static DistributedApplicationEventSubscription OnAfterResourcesCreated(this EventingSubscriberRegistrationContext context, Func<AfterResourcesCreatedEvent, Task> callback)
Eventing\DistributedApplicationEventing.cs (12)
13private readonly ConcurrentDictionary<Type, List<DistributedApplicationEventSubscription>> _eventSubscriptionListLookup = new(); 14private readonly ConcurrentDictionary<DistributedApplicationEventSubscription, Type> _subscriptionEventTypeLookup = new(); 32foreach (var subscription in subscriptions.ToArray()) 59foreach (var subscription in subscriptions.ToArray()) 68foreach (var subscription in subscriptions.ToArray()) 78DistributedApplicationEventSubscription subscription, 120public DistributedApplicationEventSubscription Subscribe<T>(Func<T, CancellationToken, Task> callback) where T : IDistributedApplicationEvent 127var subscription = new DistributedApplicationEventSubscription(async (@event, ct) => 139if (!_eventSubscriptionListLookup.TryAdd(typeof(T), new List<DistributedApplicationEventSubscription> { subscription })) 159public DistributedApplicationEventSubscription Subscribe<T>(IResource resource, Func<T, CancellationToken, Task> callback) where T : IDistributedApplicationResourceEvent 172/// <inheritdoc cref="IDistributedApplicationEventing.Unsubscribe(DistributedApplicationEventSubscription)" /> 173public 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);