ActivityItemUpdated

48 references to ActivityItemUpdated

Aspire.Hosting (9)

Backchannel\AppHostRpcTarget.cs (1)

57var publishingActivity = await activityReporter.ActivityItemUpdated.Reader.ReadAsync(cancellationToken).ConfigureAwait(false);

Pipelines\PipelineActivityReporter.cs (8)

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); 195await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 221await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 300await ActivityItemUpdated.Writer.WriteAsync(activity, cancellationToken).ConfigureAwait(false); 331await ActivityItemUpdated.Writer.WriteAsync(activity, cancellationToken).ConfigureAwait(false);

Aspire.Hosting.Tests (39)

Pipelines\DistributedApplicationPipelineTests.cs (7)

708var activityReader = reporter.ActivityItemUpdated.Reader; 749var activityReader = reporter.ActivityItemUpdated.Reader; 797var activityReader = reporter.ActivityItemUpdated.Reader; 840var activityReader = reporter.ActivityItemUpdated.Reader; 881var activityReader = reporter.ActivityItemUpdated.Reader; 925var activityReader = reporter.ActivityItemUpdated.Reader; 1082var activityReader = reporter.ActivityItemUpdated.Reader;

Publishing\PipelineActivityReporterTests.cs (32)

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; 457var activityReader = reporter.ActivityItemUpdated.Reader; 488var activityReader = reporter.ActivityItemUpdated.Reader; 517var activityReader = reporter.ActivityItemUpdated.Reader; 552var activityReader = reporter.ActivityItemUpdated.Reader; 599reporter.ActivityItemUpdated.Reader.TryRead(out _); 609var activityReader = reporter.ActivityItemUpdated.Reader; 633while (reporter.ActivityItemUpdated.Reader.TryRead(out _)) { } 643var activityReader = reporter.ActivityItemUpdated.Reader; 664while (reporter.ActivityItemUpdated.Reader.TryRead(out _)) { } 670Assert.False(reporter.ActivityItemUpdated.Reader.TryRead(out _)); 687reporter.ActivityItemUpdated.Reader.TryRead(out _); 688reporter.ActivityItemUpdated.Reader.TryRead(out _); 700var activityReader = reporter.ActivityItemUpdated.Reader; 722reporter.ActivityItemUpdated.Reader.TryRead(out _); 723reporter.ActivityItemUpdated.Reader.TryRead(out _); 735var activityReader = reporter.ActivityItemUpdated.Reader; 759var activityReader = reporter.ActivityItemUpdated.Reader; 780var activityReader = reporter.ActivityItemUpdated.Reader;