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