1 implementation of Subscribe
Aspire.Hosting (1)
Eventing\DistributedApplicationEventing.cs (1)
77
public DistributedApplicationEventSubscription
Subscribe
<T>(Func<T, CancellationToken, Task> callback) where T : IDistributedApplicationEvent
37 references to Subscribe
Aspire.Cli.Tests (1)
Hosting\CliOrphanDetectorTests.cs (1)
221
builder.Eventing.
Subscribe
<AfterResourcesCreatedEvent>((e, ct) => {
Aspire.Hosting (12)
DistributedApplicationBuilder.cs (5)
234
Eventing.
Subscribe
<BeforeStartEvent>(ExecEventingHandlers.InitializeExecResources);
386
Eventing.
Subscribe
<BeforeStartEvent>(BuiltInDistributedApplicationEventSubscriptionHandlers.InitializeDcpAnnotations);
390
Eventing.
Subscribe
<BeforeStartEvent>(BuiltInDistributedApplicationEventSubscriptionHandlers.MutateHttp2TransportAsync);
399
Eventing.
Subscribe
<BeforeStartEvent>(BuiltInDistributedApplicationEventSubscriptionHandlers.ExcludeDashboardFromManifestAsync);
404
Eventing.
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)
57
_eventing.
Subscribe
<ResourceEndpointsAllocatedEvent>(OnResourceEndpointsAllocated);
58
_eventing.
Subscribe
<ConnectionStringAvailableEvent>(PublishConnectionStringValue);
60
_eventing.
Subscribe
<BeforeResourceStartedEvent>(WaitForInBeforeResourceStartedEvent);
PublisherDistributedApplicationBuilderExtensions.cs (1)
29
builder.Eventing.
Subscribe
<PublisherAdvertisementEvent>((e, ct) => {
ResourceBuilderExtensions.cs (1)
1893
builder.ApplicationBuilder.Eventing.
Subscribe
<BeforeStartEvent>((e, ct) =>
Aspire.Hosting.Azure.CosmosDB (1)
AzureCosmosDBExtensions.cs (1)
400
builder.ApplicationBuilder.Eventing.
Subscribe
<BeforeStartEvent>((data, _) =>
Aspire.Hosting.Azure.Functions (1)
AzureFunctionsProjectResourceExtensions.cs (1)
63
builder.Eventing.
Subscribe
<BeforeStartEvent>((data, token) =>
Aspire.Hosting.Azure.PostgreSQL (1)
AzurePostgresExtensions.cs (1)
300
builder.ApplicationBuilder.Eventing.
Subscribe
<BeforeStartEvent>((data, token) =>
Aspire.Hosting.Azure.Redis (1)
AzureRedisExtensions.cs (1)
206
builder.ApplicationBuilder.Eventing.
Subscribe
<BeforeStartEvent>((data, token) =>
Aspire.Hosting.Tests (20)
Backchannel\AppHostBackchannelTests.cs (3)
24
builder.Eventing.
Subscribe
<BackchannelReadyEvent>((e, ct) => {
30
builder.Eventing.
Subscribe
<BackchannelConnectedEvent>((e, ct) => {
68
builder.Eventing.
Subscribe
<BackchannelReadyEvent>((e, ct) => {
DistributedApplicationTests.cs (1)
619
events.
Subscribe
<BeforeResourceStartedEvent>(async (e, ct) =>
Eventing\DistributedApplicationBuilderEventingTests.cs (12)
23
builder.Eventing.
Subscribe
<DummyEvent>(async (@event, ct) =>
30
builder.Eventing.
Subscribe
<DummyEvent>((@event, ct) =>
55
builder.Eventing.
Subscribe
<DummyEvent>(async (@event, ct) =>
62
builder.Eventing.
Subscribe
<DummyEvent>(async (@event, ct) =>
87
builder.Eventing.
Subscribe
<DummyEvent>(async (@event, ct) =>
94
builder.Eventing.
Subscribe
<DummyEvent>(async (@event, ct) =>
120
builder.Eventing.
Subscribe
<DummyEvent>(async (@event, ct) =>
129
builder.Eventing.
Subscribe
<DummyEvent>((@event, ct) =>
207
builder.Eventing.
Subscribe
<BeforeResourceStartedEvent>((e, ct) =>
232
builder.Eventing.
Subscribe
<BeforeStartEvent>((e, ct) =>
240
builder.Eventing.
Subscribe
<AfterEndpointsAllocatedEvent>((e, ct) =>
248
builder.Eventing.
Subscribe
<AfterResourcesCreatedEvent>((e, ct) =>
OperationModesTests.cs (4)
23
builder.Eventing.
Subscribe
<AfterResourcesCreatedEvent>((e, ct) => {
52
builder.Eventing.
Subscribe
<AfterResourcesCreatedEvent>((e, ct) => {
81
builder.Eventing.
Subscribe
<AfterResourcesCreatedEvent>((e, ct) => {
112
builder.Eventing.
Subscribe
<BeforeStartEvent>((e, ct) => {