51 references to ActivityItemUpdated
Aspire.Hosting (10)
Backchannel\AppHostRpcTarget.cs (1)
77publishingActivity = 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); 255await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 344await ActivityItemUpdated.Writer.WriteAsync(activity, cancellationToken).ConfigureAwait(false); 375await ActivityItemUpdated.Writer.WriteAsync(activity, cancellationToken).ConfigureAwait(false);
Aspire.Hosting.Tests (41)
Publishing\PipelineActivityReporterTests.cs (41)
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; 866var activityReader = reporter.ActivityItemUpdated.Reader; 889var activityReader = reporter.ActivityItemUpdated.Reader; 912var activityReader = reporter.ActivityItemUpdated.Reader; 926reporter.ActivityItemUpdated.Reader.TryRead(out _); // Clear step activity 937var activityReader = reporter.ActivityItemUpdated.Reader; 955reporter.ActivityItemUpdated.Reader.TryRead(out _); 962var activityReader = reporter.ActivityItemUpdated.Reader; 1006reporter.ActivityItemUpdated.Reader.TryRead(out _); 1007reporter.ActivityItemUpdated.Reader.TryRead(out _); 1017var activityReader = reporter.ActivityItemUpdated.Reader; 1184while (reporter.ActivityItemUpdated.Reader.TryRead(out _)) { } 1189Assert.False(reporter.ActivityItemUpdated.Reader.TryRead(out _));