1 implementation of Subscribe
Aspire.Hosting (1)
Eventing\DistributedApplicationEventing.cs (1)
77public DistributedApplicationEventSubscription Subscribe<T>(Func<T, CancellationToken, Task> callback) where T : IDistributedApplicationEvent
72 references to Subscribe
Aspire.Cli.Tests (1)
Hosting\CliOrphanDetectorTests.cs (1)
248builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) =>
Aspire.Hosting (16)
Ats\BuilderExports.cs (2)
112return builder.Eventing.Subscribe<BeforeStartEvent>(async (@event, ct) => 133return builder.Eventing.Subscribe<AfterResourcesCreatedEvent>(async (@event, ct) =>
ContainerRegistryResourceBuilderExtensions.cs (1)
121builder.Eventing.Subscribe<BeforeStartEvent>((beforeStartEvent, cancellationToken) =>
Dashboard\DashboardEventHandlers.cs (1)
847eventing.Subscribe<BeforeStartEvent>(OnBeforeStartAsync);
Devcontainers\DevcontainerPortForwardingLifecycleHook.cs (1)
61eventing.Subscribe<ResourceEndpointsAllocatedEvent>(OnResourceEndpointsAllocatedAsync);
DistributedApplicationBuilder.cs (5)
301Eventing.Subscribe<BeforeStartEvent>(ExecEventingHandlers.InitializeExecResources); 483Eventing.Subscribe<BeforeStartEvent>(BuiltInDistributedApplicationEventSubscriptionHandlers.InitializeDcpAnnotations); 487Eventing.Subscribe<BeforeStartEvent>(BuiltInDistributedApplicationEventSubscriptionHandlers.MutateHttp2TransportAsync); 542Eventing.Subscribe<BeforeStartEvent>(BuiltInDistributedApplicationEventSubscriptionHandlers.ExcludeDashboardFromManifestAsync); 547Eventing.Subscribe<BeforeStartEvent>((e, ct) => BuiltInDistributedApplicationEventSubscriptionHandlers.UpdateContainerRegistryAsync(e, options));
Eventing\DistributedApplicationEventing.cs (2)
76/// <inheritdoc cref="IDistributedApplicationEventing.Subscribe{T}(Func{T, CancellationToken, Task})" /> 105/// <inheritdoc cref="IDistributedApplicationEventing.Subscribe{T}(Func{T, CancellationToken, Task})" />
Orchestrator\ApplicationOrchestrator.cs (3)
73_eventing.Subscribe<ResourceEndpointsAllocatedEvent>(OnResourceEndpointsAllocated); 74_eventing.Subscribe<ConnectionStringAvailableEvent>(PublishConnectionStringValue); 76_eventing.Subscribe<BeforeResourceStartedEvent>(WaitForInBeforeResourceStartedEvent);
PublisherDistributedApplicationBuilderExtensions.cs (1)
30builder.Eventing.Subscribe<PublisherAdvertisementEvent>((e, ct) => {
Aspire.Hosting.Azure (2)
AzureResourcePreparer.cs (1)
439eventing.Subscribe<BeforeStartEvent>(OnBeforeStartAsync);
Provisioning\Provisioners\AzureProvisioner.cs (1)
284eventing.Subscribe<BeforeStartEvent>(OnBeforeStartAsync);
Aspire.Hosting.Azure.AppContainers (1)
AzureContainerAppsInfrastructure.cs (1)
80eventing.Subscribe<BeforeStartEvent>(OnBeforeStartAsync);
Aspire.Hosting.Azure.AppService (1)
AzureAppServiceInfrastructure.cs (1)
83eventing.Subscribe<BeforeStartEvent>(OnBeforeStartAsync);
Aspire.Hosting.Azure.ContainerRegistry (1)
AzureContainerRegistryExtensions.cs (1)
79builder.Eventing.Subscribe<BeforeStartEvent>((beforeStartEvent, cancellationToken) =>
Aspire.Hosting.Azure.CosmosDB (1)
AzureCosmosDBExtensions.cs (1)
411builder.ApplicationBuilder.Eventing.Subscribe<BeforeStartEvent>((data, _) =>
Aspire.Hosting.Azure.Functions (1)
AzureFunctionsProjectResourceExtensions.cs (1)
156builder.Eventing.Subscribe<BeforeStartEvent>((data, token) =>
Aspire.Hosting.Azure.PostgreSQL (1)
AzurePostgresExtensions.cs (1)
303builder.ApplicationBuilder.Eventing.Subscribe<BeforeStartEvent>((data, token) =>
Aspire.Hosting.Azure.Redis (2)
AzureManagedRedisExtensions.cs (1)
136builder.ApplicationBuilder.Eventing.Subscribe<BeforeStartEvent>((data, token) =>
AzureRedisExtensions.cs (1)
209builder.ApplicationBuilder.Eventing.Subscribe<BeforeStartEvent>((data, token) =>
Aspire.Hosting.Docker (1)
DockerComposeInfrastructure.cs (1)
122eventing.Subscribe<BeforeStartEvent>(OnBeforeStartAsync);
Aspire.Hosting.JavaScript (4)
JavaScriptHostingExtensions.cs (4)
263builder.Eventing.Subscribe<BeforeStartEvent>((_, _) => 465builder.Eventing.Subscribe<BeforeStartEvent>((_, _) => 633builder.Eventing.Subscribe<BeforeStartEvent>((@event, _) => 909resource.ApplicationBuilder.Eventing.Subscribe<BeforeStartEvent>((_, _) =>
Aspire.Hosting.Keycloak (1)
KeycloakResourceBuilderExtensions.cs (1)
109builder.Eventing.Subscribe<BeforeStartEvent>((@event, cancellationToken) =>
Aspire.Hosting.Kubernetes (1)
KubernetesInfrastructure.cs (1)
66eventing.Subscribe<BeforeStartEvent>(OnBeforeStartAsync);
Aspire.Hosting.Maui (4)
Lifecycle\UnsupportedPlatformEventSubscriber.cs (1)
25eventing.Subscribe<AfterResourcesCreatedEvent>(async (@event, ct) =>
MauiOtlpExtensions.cs (1)
118appBuilder.Eventing.Subscribe<BeforeStartEvent>((evt, ct) =>
Utilities\MauiAndroidEnvironmentAnnotation.cs (1)
49eventing.Subscribe<BeforeResourceStartedEvent>(OnBeforeResourceStartedAsync);
Utilities\MauiiOSEnvironmentAnnotation.cs (1)
49eventing.Subscribe<BeforeResourceStartedEvent>(OnBeforeResourceStartedAsync);
Aspire.Hosting.Python (3)
PythonAppResourceBuilderExtensions.cs (3)
316builder.Eventing.Subscribe<BeforeStartEvent>((@event, cancellationToken) => 516builder.Eventing.Subscribe<BeforeStartEvent>((evt, ct) => 1369builder.ApplicationBuilder.Eventing.Subscribe<BeforeStartEvent>((_, _) =>
Aspire.Hosting.Redis (2)
RedisBuilderExtensions.cs (2)
178builder.Eventing.Subscribe<BeforeStartEvent>((@event, cancellationToken) => 390builder.ApplicationBuilder.Eventing.Subscribe<BeforeStartEvent>((@event, cancellationToken) =>
Aspire.Hosting.Tests (23)
Backchannel\AppHostBackchannelTests.cs (3)
23builder.Eventing.Subscribe<BackchannelReadyEvent>((e, ct) => { 29builder.Eventing.Subscribe<BackchannelConnectedEvent>((e, ct) => { 67builder.Eventing.Subscribe<BackchannelReadyEvent>((e, ct) => {
Backchannel\AuxiliaryBackchannelTests.cs (2)
25builder.Eventing.Subscribe<AuxiliaryBackchannelConnectedEvent>((e, ct) => 65builder.Eventing.Subscribe<AuxiliaryBackchannelConnectedEvent>((e, ct) =>
DistributedApplicationTests.cs (2)
266testProgram.AppBuilder.Eventing.Subscribe<AfterResourcesCreatedEvent>((_, _) => 1066events.Subscribe<BeforeResourceStartedEvent>(async (e, ct) =>
Eventing\DistributedApplicationBuilderEventingTests.cs (12)
23builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 30builder.Eventing.Subscribe<DummyEvent>((@event, ct) => 55builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 62builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 87builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 94builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 120builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 129builder.Eventing.Subscribe<DummyEvent>((@event, ct) => 207builder.Eventing.Subscribe<BeforeResourceStartedEvent>((e, ct) => 232builder.Eventing.Subscribe<BeforeStartEvent>((e, ct) => 240builder.Eventing.Subscribe<AfterEndpointsAllocatedEvent>((e, ct) => 248builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) =>
OperationModesTests.cs (4)
23builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) => { 52builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) => { 81builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) => { 112builder.Eventing.Subscribe<BeforeStartEvent>((e, ct) => {
Aspire.Hosting.Yarp (1)
YarpResourceExtensions.cs (1)
58builder.Eventing.Subscribe<BeforeStartEvent>((@event, cancellationToken) =>
CustomResources.AppHost (1)
TestResource.cs (1)
86eventing.Subscribe<BeforeStartEvent>(OnBeforeStartAsync);
DotnetTool.AppHost (1)
AppHost.cs (1)
85builder.Eventing.Subscribe<BeforeStartEvent>(async (evt, _) =>
HealthChecksSandbox.AppHost (1)
Program.cs (1)
87eventing.Subscribe<BeforeStartEvent>(OnBeforeStartAsync);
Stress.AppHost (1)
TestResource.cs (1)
104eventing.Subscribe<BeforeStartEvent>(OnBeforeStartAsync);
TestProject.AppHost (1)
TestProgram.cs (1)
205eventing.Subscribe<AfterResourcesCreatedEvent>(OnAfterResourcesCreated);