7 instantiations of PublishingActivity
Aspire.Hosting (7)
Publishing\PublishingActivityReporter.cs (7)
41var state = new PublishingActivity 77var state = new PublishingActivity 107var state = new PublishingActivity 139var state = new PublishingActivity 177var state = new PublishingActivity 199var state = new PublishingActivity 299var activity = new PublishingActivity
26 references to PublishingActivity
Aspire.Hosting (11)
Backchannel\AppHostRpcTarget.cs (2)
53public async IAsyncEnumerable<PublishingActivity> GetPublishingActivitiesAsync([EnumeratorCancellation] CancellationToken cancellationToken) 57var publishingActivity = await activityReporter.ActivityItemUpdated.Reader.ReadAsync(cancellationToken).ConfigureAwait(false);
Publishing\PublishingActivityReporter.cs (9)
41var state = new PublishingActivity 77var state = new PublishingActivity 107var state = new PublishingActivity 139var state = new PublishingActivity 177var state = new PublishingActivity 199var state = new PublishingActivity 299var activity = new PublishingActivity 369internal Channel<PublishingActivity> ActivityItemUpdated { get; } = Channel.CreateUnbounded<PublishingActivity>();
Aspire.Hosting.Tests (15)
Publishing\PublishingActivityReporterTests.cs (15)
40Assert.True(activityReader.TryRead(out var activity)); 79Assert.True(activityReader.TryRead(out var activity)); 144Assert.True(activityReader.TryRead(out var activity)); 177Assert.True(activityReader.TryRead(out var activity)); 250Assert.True(activityReader.TryRead(out var activity)); 293Assert.True(activityReader.TryRead(out var activity)); 314Assert.True(activityReader.TryRead(out var activity)); 353Assert.True(activityReader.TryRead(out var activity)); 477var activity = await activityReader.ReadAsync().DefaultTimeout(); 529Assert.True(activityReader.TryRead(out var activity)); 563Assert.True(activityReader.TryRead(out var activity)); 620Assert.True(activityReader.TryRead(out var activity)); 655Assert.True(activityReader.TryRead(out var activity)); 679Assert.True(activityReader.TryRead(out var activity)); 700Assert.True(activityReader.TryRead(out var activity));