49 references to ActivityItemUpdated
Aspire.Hosting (10)
Backchannel\AppHostRpcTarget.cs (1)
81publishingActivity = await activityReporter.ActivityItemUpdated.Reader.ReadAsync(linkedToken).ConfigureAwait(false);
Pipelines\PipelineActivityReporter.cs (9)
58await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 94await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 124await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 156await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 189ActivityItemUpdated.Writer.TryWrite(state); 229await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 254await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 333await ActivityItemUpdated.Writer.WriteAsync(activity, cancellationToken).ConfigureAwait(false); 364await ActivityItemUpdated.Writer.WriteAsync(activity, cancellationToken).ConfigureAwait(false);
Aspire.Hosting.Tests (39)
Publishing\PipelineActivityReporterTests.cs (39)
40var activityReader = reporter.ActivityItemUpdated.Reader; 63reporter.ActivityItemUpdated.Reader.TryRead(out _); 79var activityReader = reporter.ActivityItemUpdated.Reader; 133reporter.ActivityItemUpdated.Reader.TryRead(out _); 144var activityReader = reporter.ActivityItemUpdated.Reader; 165reporter.ActivityItemUpdated.Reader.TryRead(out _); 166reporter.ActivityItemUpdated.Reader.TryRead(out _); 177var activityReader = reporter.ActivityItemUpdated.Reader; 237reporter.ActivityItemUpdated.Reader.TryRead(out _); 238reporter.ActivityItemUpdated.Reader.TryRead(out _); 250var activityReader = reporter.ActivityItemUpdated.Reader; 293var activityReader = reporter.ActivityItemUpdated.Reader; 314var activityReader = reporter.ActivityItemUpdated.Reader; 347var activityReader = reporter.ActivityItemUpdated.Reader; 517var activityReader = reporter.ActivityItemUpdated.Reader; 548var activityReader = reporter.ActivityItemUpdated.Reader; 577var activityReader = reporter.ActivityItemUpdated.Reader; 612var activityReader = reporter.ActivityItemUpdated.Reader; 659reporter.ActivityItemUpdated.Reader.TryRead(out _); 669var activityReader = reporter.ActivityItemUpdated.Reader; 703var activityReader = reporter.ActivityItemUpdated.Reader; 747reporter.ActivityItemUpdated.Reader.TryRead(out _); 748reporter.ActivityItemUpdated.Reader.TryRead(out _); 760var activityReader = reporter.ActivityItemUpdated.Reader; 782reporter.ActivityItemUpdated.Reader.TryRead(out _); 783reporter.ActivityItemUpdated.Reader.TryRead(out _); 795var activityReader = reporter.ActivityItemUpdated.Reader; 819var activityReader = reporter.ActivityItemUpdated.Reader; 840var activityReader = reporter.ActivityItemUpdated.Reader; 865var activityReader = reporter.ActivityItemUpdated.Reader; 879reporter.ActivityItemUpdated.Reader.TryRead(out _); // Clear step activity 890var activityReader = reporter.ActivityItemUpdated.Reader; 908reporter.ActivityItemUpdated.Reader.TryRead(out _); 915var activityReader = reporter.ActivityItemUpdated.Reader; 959reporter.ActivityItemUpdated.Reader.TryRead(out _); 960reporter.ActivityItemUpdated.Reader.TryRead(out _); 970var activityReader = reporter.ActivityItemUpdated.Reader; 1137while (reporter.ActivityItemUpdated.Reader.TryRead(out _)) { } 1142Assert.False(reporter.ActivityItemUpdated.Reader.TryRead(out _));