1 implementation of PublishAsync
Aspire.Hosting (1)
Eventing\DistributedApplicationEventing.cs (1)
19public async Task PublishAsync<T>(T @event, CancellationToken cancellationToken = default) where T : IDistributedApplicationEvent
17 references to PublishAsync
Aspire.Hosting (1)
Eventing\DistributedApplicationEventing.cs (1)
17/// <inheritdoc cref="IDistributedApplicationEventing.PublishAsync{T}(T, CancellationToken)" />
Aspire.Hosting.Milvus (2)
MilvusBuilderExtensions.cs (2)
76await builder.Eventing.PublishAsync<ConnectionStringAvailableEvent>(connectionStringAvailableEvent, ct).ConfigureAwait(false); 79await builder.Eventing.PublishAsync(beforeResourceStartedEvent, ct).ConfigureAwait(false);
Aspire.Hosting.MySql (2)
MySqlBuilderExtensions.cs (2)
56await builder.Eventing.PublishAsync<ConnectionStringAvailableEvent>(connectionStringAvailableEvent, ct).ConfigureAwait(false); 59await builder.Eventing.PublishAsync(beforeResourceStartedEvent, ct).ConfigureAwait(false);
Aspire.Hosting.MySql.Tests (2)
AddMySqlTests.cs (2)
243await builder.Eventing.PublishAsync<AfterEndpointsAllocatedEvent>(new(app.Services, app.Services.GetRequiredService<DistributedApplicationModel>())); 284builder.Eventing.PublishAsync<AfterEndpointsAllocatedEvent>(new(app.Services, app.Services.GetRequiredService<DistributedApplicationModel>()));
Aspire.Hosting.Oracle (2)
OracleDatabaseBuilderExtensions.cs (2)
52await builder.Eventing.PublishAsync<ConnectionStringAvailableEvent>(connectionStringAvailableEvent, ct).ConfigureAwait(false); 55await builder.Eventing.PublishAsync(beforeResourceStartedEvent, ct).ConfigureAwait(false);
Aspire.Hosting.PostgreSQL (2)
PostgresBuilderExtensions.cs (2)
72await builder.Eventing.PublishAsync<ConnectionStringAvailableEvent>(connectionStringAvailableEvent, ct).ConfigureAwait(false); 75await builder.Eventing.PublishAsync(beforeResourceStartedEvent, ct).ConfigureAwait(false);
Aspire.Hosting.PostgreSQL.Tests (2)
AddPostgresTests.cs (2)
467await builder.Eventing.PublishAsync<AfterEndpointsAllocatedEvent>(new(app.Services, app.Services.GetRequiredService<DistributedApplicationModel>())); 515await builder.Eventing.PublishAsync<AfterEndpointsAllocatedEvent>(new(app.Services, app.Services.GetRequiredService<DistributedApplicationModel>()));
Aspire.Hosting.Redis.Tests (2)
AddRedisTests.cs (2)
216await builder.Eventing.PublishAsync<AfterEndpointsAllocatedEvent>(new(app.Services, app.Services.GetRequiredService<DistributedApplicationModel>())); 240await builder.Eventing.PublishAsync<AfterEndpointsAllocatedEvent>(new (app.Services, app.Services.GetRequiredService<DistributedApplicationModel>()));
Aspire.Hosting.SqlServer (2)
SqlServerBuilderExtensions.cs (2)
54await builder.Eventing.PublishAsync<ConnectionStringAvailableEvent>(connectionStringAvailableEvent, ct).ConfigureAwait(false); 57await builder.Eventing.PublishAsync(beforeResourceStartedEvent, ct).ConfigureAwait(false);