9 instantiations of PublishingActivity
Aspire.Hosting (9)
Pipelines\PipelineActivityReporter.cs (9)
70var state = new PublishingActivity 100var state = new PublishingActivity 131var state = new PublishingActivity 157var state = new PublishingActivity 188var state = new PublishingActivity 230var state = new PublishingActivity 252var state = new PublishingActivity 355var activity = new PublishingActivity 386var activity = new PublishingActivity
49 references to PublishingActivity
Aspire.Hosting (13)
Backchannel\AppHostRpcTarget.cs (2)
72public async IAsyncEnumerable<PublishingActivity> GetPublishingActivitiesAsync([EnumeratorCancellation] CancellationToken cancellationToken) 86PublishingActivity? publishingActivity = null;
Pipelines\PipelineActivityReporter.cs (11)
70var state = new PublishingActivity 100var state = new PublishingActivity 131var state = new PublishingActivity 157var state = new PublishingActivity 188var state = new PublishingActivity 230var state = new PublishingActivity 252var state = new PublishingActivity 355var activity = new PublishingActivity 386var activity = new PublishingActivity 521internal Channel<PublishingActivity> ActivityItemUpdated { get; } = Channel.CreateUnbounded<PublishingActivity>();
Aspire.Hosting.Tests (36)
Backchannel\AppHostRpcTargetCancellationTests.cs (3)
108await foreach (var _ in target.GetPublishingActivitiesAsync(cts.Token)) 128await foreach (var _ in target.GetPublishingActivitiesAsync(cts.Token)) 151await foreach (var _ in target.GetPublishingActivitiesAsync(CancellationToken.None))
Publishing\PipelineActivityReporterTests.cs (33)
42Assert.True(activityReader.TryRead(out var activity)); 67Assert.True(activityReader.TryRead(out var createActivity)); 73Assert.True(activityReader.TryRead(out var completeActivity)); 95Assert.True(activityReader.TryRead(out var createActivity)); 129Assert.True(activityReader.TryRead(out var activity)); 194Assert.True(activityReader.TryRead(out var activity)); 227Assert.True(activityReader.TryRead(out var activity)); 300Assert.True(activityReader.TryRead(out var activity)); 343Assert.True(activityReader.TryRead(out var activity)); 364Assert.True(activityReader.TryRead(out var activity)); 403Assert.True(activityReader.TryRead(out var activity)); 571var activity = await activityReader.ReadAsync().DefaultTimeout(); 598var activity = await activityReader.ReadAsync().DefaultTimeout(); 627var activity = await activityReader.ReadAsync().DefaultTimeout(); 656var activity = await reporter.ActivityItemUpdated.Reader.ReadAsync().DefaultTimeout(); 696var activity = await reporter.ActivityItemUpdated.Reader.ReadAsync().DefaultTimeout(); 726var activity = await activityReader.ReadAsync().DefaultTimeout(); 783Assert.True(activityReader.TryRead(out var activity)); 817Assert.True(activityReader.TryRead(out var activity)); 874Assert.True(activityReader.TryRead(out var activity)); 909Assert.True(activityReader.TryRead(out var activity)); 933Assert.True(activityReader.TryRead(out var activity)); 954Assert.True(activityReader.TryRead(out var activity)); 980Assert.True(activityReader.TryRead(out var activity)); 1007Assert.True(activityReader.TryRead(out var activity)); 1030Assert.True(activityReader.TryRead(out var activity)); 1055Assert.True(activityReader.TryRead(out var activity)); 1080Assert.True(activityReader.TryRead(out var activity)); 1135Assert.True(activityReader.TryRead(out var activity)); 1154Assert.True(activityReader.TryRead(out var activity)); 1174Assert.True(activityReader.TryRead(out var activity)); 1194Assert.True(activityReader.TryRead(out var activity)); 1213Assert.True(activityReader.TryRead(out var activity));