9 instantiations of PublishingActivity
Aspire.Hosting (9)
Pipelines\PipelineActivityReporter.cs (9)
46var state = new PublishingActivity 82var state = new PublishingActivity 113var state = new PublishingActivity 146var state = new PublishingActivity 177var state = new PublishingActivity 219var state = new PublishingActivity 241var state = new PublishingActivity 341var activity = new PublishingActivity 372var activity = new PublishingActivity
41 references to PublishingActivity
Aspire.Hosting (13)
Backchannel\AppHostRpcTarget.cs (2)
59public async IAsyncEnumerable<PublishingActivity> GetPublishingActivitiesAsync([EnumeratorCancellation] CancellationToken cancellationToken) 67PublishingActivity? publishingActivity = null;
Pipelines\PipelineActivityReporter.cs (11)
46var state = new PublishingActivity 82var state = new PublishingActivity 113var state = new PublishingActivity 146var state = new PublishingActivity 177var state = new PublishingActivity 219var state = new PublishingActivity 241var state = new PublishingActivity 341var activity = new PublishingActivity 372var activity = new PublishingActivity 486internal Channel<PublishingActivity> ActivityItemUpdated { get; } = Channel.CreateUnbounded<PublishingActivity>();
Aspire.Hosting.Tests (28)
Publishing\PipelineActivityReporterTests.cs (28)
42Assert.True(activityReader.TryRead(out var activity)); 81Assert.True(activityReader.TryRead(out var activity)); 146Assert.True(activityReader.TryRead(out var activity)); 179Assert.True(activityReader.TryRead(out var activity)); 252Assert.True(activityReader.TryRead(out var activity)); 295Assert.True(activityReader.TryRead(out var activity)); 316Assert.True(activityReader.TryRead(out var activity)); 355Assert.True(activityReader.TryRead(out var activity)); 523var activity = await activityReader.ReadAsync().DefaultTimeout(); 550var activity = await activityReader.ReadAsync().DefaultTimeout(); 579var activity = await activityReader.ReadAsync().DefaultTimeout(); 614var activity = await activityReader.ReadAsync().DefaultTimeout(); 671Assert.True(activityReader.TryRead(out var activity)); 705Assert.True(activityReader.TryRead(out var activity)); 762Assert.True(activityReader.TryRead(out var activity)); 797Assert.True(activityReader.TryRead(out var activity)); 821Assert.True(activityReader.TryRead(out var activity)); 842Assert.True(activityReader.TryRead(out var activity)); 868Assert.True(activityReader.TryRead(out var activity)); 895Assert.True(activityReader.TryRead(out var activity)); 918Assert.True(activityReader.TryRead(out var activity)); 943Assert.True(activityReader.TryRead(out var activity)); 968Assert.True(activityReader.TryRead(out var activity)); 1023Assert.True(activityReader.TryRead(out var activity)); 1042Assert.True(activityReader.TryRead(out var activity)); 1062Assert.True(activityReader.TryRead(out var activity)); 1082Assert.True(activityReader.TryRead(out var activity)); 1101Assert.True(activityReader.TryRead(out var activity));