9 instantiations of PublishingActivity
Aspire.Hosting (9)
Pipelines\PipelineActivityReporter.cs (9)
72var state = new PublishingActivity 102var state = new PublishingActivity 133var state = new PublishingActivity 159var state = new PublishingActivity 190var state = new PublishingActivity 232var state = new PublishingActivity 254var state = new PublishingActivity 357var activity = new PublishingActivity 388var 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)
72var state = new PublishingActivity 102var state = new PublishingActivity 133var state = new PublishingActivity 159var state = new PublishingActivity 190var state = new PublishingActivity 232var state = new PublishingActivity 254var state = new PublishingActivity 357var activity = new PublishingActivity 388var activity = new PublishingActivity 523internal 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)
44Assert.True(activityReader.TryRead(out var activity)); 69Assert.True(activityReader.TryRead(out var createActivity)); 75Assert.True(activityReader.TryRead(out var completeActivity)); 97Assert.True(activityReader.TryRead(out var createActivity)); 131Assert.True(activityReader.TryRead(out var activity)); 196Assert.True(activityReader.TryRead(out var activity)); 229Assert.True(activityReader.TryRead(out var activity)); 302Assert.True(activityReader.TryRead(out var activity)); 345Assert.True(activityReader.TryRead(out var activity)); 366Assert.True(activityReader.TryRead(out var activity)); 405Assert.True(activityReader.TryRead(out var activity)); 573var activity = await activityReader.ReadAsync().DefaultTimeout(); 600var activity = await activityReader.ReadAsync().DefaultTimeout(); 629var activity = await activityReader.ReadAsync().DefaultTimeout(); 658var activity = await reporter.ActivityItemUpdated.Reader.ReadAsync().DefaultTimeout(); 698var activity = await reporter.ActivityItemUpdated.Reader.ReadAsync().DefaultTimeout(); 728var activity = await activityReader.ReadAsync().DefaultTimeout(); 785Assert.True(activityReader.TryRead(out var activity)); 819Assert.True(activityReader.TryRead(out var activity)); 876Assert.True(activityReader.TryRead(out var activity)); 911Assert.True(activityReader.TryRead(out var activity)); 935Assert.True(activityReader.TryRead(out var activity)); 956Assert.True(activityReader.TryRead(out var activity)); 982Assert.True(activityReader.TryRead(out var activity)); 1009Assert.True(activityReader.TryRead(out var activity)); 1032Assert.True(activityReader.TryRead(out var activity)); 1057Assert.True(activityReader.TryRead(out var activity)); 1082Assert.True(activityReader.TryRead(out var activity)); 1137Assert.True(activityReader.TryRead(out var activity)); 1156Assert.True(activityReader.TryRead(out var activity)); 1176Assert.True(activityReader.TryRead(out var activity)); 1196Assert.True(activityReader.TryRead(out var activity)); 1215Assert.True(activityReader.TryRead(out var activity));