ActivityItemUpdated

40 references to ActivityItemUpdated

Aspire.Hosting (9)

Backchannel\AppHostRpcTarget.cs (1)

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

Publishing\PublishingActivityReporter.cs (8)

53await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 89await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 119await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 151await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 190await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 216await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 308await ActivityItemUpdated.Writer.WriteAsync(activity, cancellationToken).ConfigureAwait(false); 338await ActivityItemUpdated.Writer.WriteAsync(activity, cancellationToken).ConfigureAwait(false);

Aspire.Hosting.Tests (31)

Publishing\PublishingActivityReporterTests.cs (31)

39var activityReader = reporter.ActivityItemUpdated.Reader; 62reporter.ActivityItemUpdated.Reader.TryRead(out _); 78var activityReader = reporter.ActivityItemUpdated.Reader; 132reporter.ActivityItemUpdated.Reader.TryRead(out _); 143var activityReader = reporter.ActivityItemUpdated.Reader; 164reporter.ActivityItemUpdated.Reader.TryRead(out _); 165reporter.ActivityItemUpdated.Reader.TryRead(out _); 176var activityReader = reporter.ActivityItemUpdated.Reader; 236reporter.ActivityItemUpdated.Reader.TryRead(out _); 237reporter.ActivityItemUpdated.Reader.TryRead(out _); 249var activityReader = reporter.ActivityItemUpdated.Reader; 292var activityReader = reporter.ActivityItemUpdated.Reader; 313var activityReader = reporter.ActivityItemUpdated.Reader; 346var activityReader = reporter.ActivityItemUpdated.Reader; 458var activityReader = reporter.ActivityItemUpdated.Reader; 476var activityReader = reporter.ActivityItemUpdated.Reader; 511var activityReader = reporter.ActivityItemUpdated.Reader; 558reporter.ActivityItemUpdated.Reader.TryRead(out _); 568var activityReader = reporter.ActivityItemUpdated.Reader; 592while (reporter.ActivityItemUpdated.Reader.TryRead(out _)) { } 602var activityReader = reporter.ActivityItemUpdated.Reader; 623while (reporter.ActivityItemUpdated.Reader.TryRead(out _)) { } 629Assert.False(reporter.ActivityItemUpdated.Reader.TryRead(out _)); 646reporter.ActivityItemUpdated.Reader.TryRead(out _); 647reporter.ActivityItemUpdated.Reader.TryRead(out _); 659var activityReader = reporter.ActivityItemUpdated.Reader; 681reporter.ActivityItemUpdated.Reader.TryRead(out _); 682reporter.ActivityItemUpdated.Reader.TryRead(out _); 694var activityReader = reporter.ActivityItemUpdated.Reader; 718var activityReader = reporter.ActivityItemUpdated.Reader; 739var activityReader = reporter.ActivityItemUpdated.Reader;