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 321var activity = new PublishingActivity 352var activity = new PublishingActivity
35 references to PublishingActivity
Aspire.Hosting (13)
Backchannel\AppHostRpcTarget.cs (2)
69public async IAsyncEnumerable<PublishingActivity> GetPublishingActivitiesAsync([EnumeratorCancellation] CancellationToken cancellationToken) 77PublishingActivity? 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 321var activity = new PublishingActivity 352var activity = new PublishingActivity 466internal Channel<PublishingActivity> ActivityItemUpdated { get; } = Channel.CreateUnbounded<PublishingActivity>();
Aspire.Hosting.Tests (22)
Publishing\PipelineActivityReporterTests.cs (22)
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)); 866Assert.True(activityReader.TryRead(out var activity)); 891Assert.True(activityReader.TryRead(out var activity)); 916Assert.True(activityReader.TryRead(out var activity)); 971Assert.True(activityReader.TryRead(out var activity));