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
49 references to PublishingActivity
Aspire.Hosting (13)
Backchannel\AppHostRpcTarget.cs (2)
53public async IAsyncEnumerable<PublishingActivity> GetPublishingActivitiesAsync([EnumeratorCancellation] CancellationToken cancellationToken) 57var publishingActivity = await activityReporter.ActivityItemUpdated.Reader.ReadAsync(cancellationToken).ConfigureAwait(false);
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 (36)
Pipelines\DistributedApplicationPipelineTests.cs (14)
802while (activityReader.TryRead(out var activity)) 1081var activities = new List<PublishingActivity>(); 1082while (reporter.ActivityItemUpdated.Reader.TryRead(out var activity)) 1105var testLogActivity = logActivities.SingleOrDefault(l => l.Data.StatusText == "Test log message from pipeline step"); 1162var activities = new List<PublishingActivity>(); 1163while (reporter.ActivityItemUpdated.Reader.TryRead(out var activity)) 1255var activities = new List<PublishingActivity>(); 1256while (reporter.ActivityItemUpdated.Reader.TryRead(out var activity)) 1277var aboutToFailLogActivity = logActivities.SingleOrDefault(l => l.Data.StatusText == "About to fail"); 1337var activities = new List<PublishingActivity>(); 1338while (reporter.ActivityItemUpdated.Reader.TryRead(out var activity)) 1374foreach (var logActivity in logActivities) 1434var activities = new List<PublishingActivity>(); 1435while (reporter.ActivityItemUpdated.Reader.TryRead(out var activity))
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));