8 instantiations of PublishingActivity
Aspire.Hosting (8)
Publishing\PublishingActivityReporter.cs (8)
41var state = new PublishingActivity 77var state = new PublishingActivity 107var state = new PublishingActivity 139var state = new PublishingActivity 177var state = new PublishingActivity 199var state = new PublishingActivity 296var activity = new PublishingActivity 326var activity = new PublishingActivity
28 references to PublishingActivity
Aspire.Hosting (12)
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 (10)
41var state = new PublishingActivity 77var state = new PublishingActivity 107var state = new PublishingActivity 139var state = new PublishingActivity 177var state = new PublishingActivity 199var state = new PublishingActivity 296var activity = new PublishingActivity 326var activity = new PublishingActivity 413internal Channel<PublishingActivity> ActivityItemUpdated { get; } = Channel.CreateUnbounded<PublishingActivity>();
Aspire.Hosting.Tests (16)
Publishing\PublishingActivityReporterTests.cs (16)
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(); 512var activity = await activityReader.ReadAsync().DefaultTimeout(); 569Assert.True(activityReader.TryRead(out var activity)); 603Assert.True(activityReader.TryRead(out var activity)); 660Assert.True(activityReader.TryRead(out var activity)); 695Assert.True(activityReader.TryRead(out var activity)); 719Assert.True(activityReader.TryRead(out var activity)); 740Assert.True(activityReader.TryRead(out var activity));