9 instantiations of PublishingActivity
Aspire.Hosting (9)
Pipelines\PipelineActivityReporter.cs (9)
46var state = new PublishingActivity 82var state = new PublishingActivity 112var state = new PublishingActivity 144var state = new PublishingActivity 174var state = new PublishingActivity 216var state = new PublishingActivity 237var state = new PublishingActivity 332var activity = new PublishingActivity 363var activity = new PublishingActivity
37 references to PublishingActivity
Aspire.Hosting (13)
Backchannel\AppHostRpcTarget.cs (2)
65public async IAsyncEnumerable<PublishingActivity> GetPublishingActivitiesAsync([EnumeratorCancellation] CancellationToken cancellationToken) 73PublishingActivity? publishingActivity = null;
Pipelines\PipelineActivityReporter.cs (11)
46var state = new PublishingActivity 82var state = new PublishingActivity 112var state = new PublishingActivity 144var state = new PublishingActivity 174var state = new PublishingActivity 216var state = new PublishingActivity 237var state = new PublishingActivity 332var activity = new PublishingActivity 363var activity = new PublishingActivity 477internal Channel<PublishingActivity> ActivityItemUpdated { get; } = Channel.CreateUnbounded<PublishingActivity>();
Aspire.Hosting.Tests (24)
Publishing\PipelineActivityReporterTests.cs (24)
41Assert.True(activityReader.TryRead(out var activity)); 80Assert.True(activityReader.TryRead(out var activity)); 145Assert.True(activityReader.TryRead(out var activity)); 178Assert.True(activityReader.TryRead(out var activity)); 251Assert.True(activityReader.TryRead(out var activity)); 294Assert.True(activityReader.TryRead(out var activity)); 315Assert.True(activityReader.TryRead(out var activity)); 354Assert.True(activityReader.TryRead(out var activity)); 522var activity = await activityReader.ReadAsync().DefaultTimeout(); 549var activity = await activityReader.ReadAsync().DefaultTimeout(); 578var activity = await activityReader.ReadAsync().DefaultTimeout(); 613var activity = await activityReader.ReadAsync().DefaultTimeout(); 670Assert.True(activityReader.TryRead(out var activity)); 704Assert.True(activityReader.TryRead(out var activity)); 761Assert.True(activityReader.TryRead(out var activity)); 796Assert.True(activityReader.TryRead(out var activity)); 820Assert.True(activityReader.TryRead(out var activity)); 841Assert.True(activityReader.TryRead(out var activity)); 867Assert.True(activityReader.TryRead(out var activity)); 890Assert.True(activityReader.TryRead(out var activity)); 913Assert.True(activityReader.TryRead(out var activity)); 938Assert.True(activityReader.TryRead(out var activity)); 963Assert.True(activityReader.TryRead(out var activity)); 1018Assert.True(activityReader.TryRead(out var activity));