56 references to ActivityItemUpdated
Aspire.Hosting (10)
Backchannel\AppHostRpcTarget.cs (1)
71publishingActivity = await activityReporter.ActivityItemUpdated.Reader.ReadAsync(linkedToken).ConfigureAwait(false);
Pipelines\PipelineActivityReporter.cs (9)
58await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 95await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 126await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 159await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 192ActivityItemUpdated.Writer.TryWrite(state); 233await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 264await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 353await ActivityItemUpdated.Writer.WriteAsync(activity, cancellationToken).ConfigureAwait(false); 384await ActivityItemUpdated.Writer.WriteAsync(activity, cancellationToken).ConfigureAwait(false);
Aspire.Hosting.Tests (46)
Publishing\PipelineActivityReporterTests.cs (46)
41var activityReader = reporter.ActivityItemUpdated.Reader; 64reporter.ActivityItemUpdated.Reader.TryRead(out _); 80var activityReader = reporter.ActivityItemUpdated.Reader; 134reporter.ActivityItemUpdated.Reader.TryRead(out _); 145var activityReader = reporter.ActivityItemUpdated.Reader; 166reporter.ActivityItemUpdated.Reader.TryRead(out _); 167reporter.ActivityItemUpdated.Reader.TryRead(out _); 178var activityReader = reporter.ActivityItemUpdated.Reader; 238reporter.ActivityItemUpdated.Reader.TryRead(out _); 239reporter.ActivityItemUpdated.Reader.TryRead(out _); 251var activityReader = reporter.ActivityItemUpdated.Reader; 294var activityReader = reporter.ActivityItemUpdated.Reader; 315var activityReader = reporter.ActivityItemUpdated.Reader; 348var activityReader = reporter.ActivityItemUpdated.Reader; 518var activityReader = reporter.ActivityItemUpdated.Reader; 549var activityReader = reporter.ActivityItemUpdated.Reader; 578var activityReader = reporter.ActivityItemUpdated.Reader; 613var activityReader = reporter.ActivityItemUpdated.Reader; 660reporter.ActivityItemUpdated.Reader.TryRead(out _); 670var activityReader = reporter.ActivityItemUpdated.Reader; 704var activityReader = reporter.ActivityItemUpdated.Reader; 748reporter.ActivityItemUpdated.Reader.TryRead(out _); 749reporter.ActivityItemUpdated.Reader.TryRead(out _); 761var activityReader = reporter.ActivityItemUpdated.Reader; 783reporter.ActivityItemUpdated.Reader.TryRead(out _); 784reporter.ActivityItemUpdated.Reader.TryRead(out _); 796var activityReader = reporter.ActivityItemUpdated.Reader; 820var activityReader = reporter.ActivityItemUpdated.Reader; 841var activityReader = reporter.ActivityItemUpdated.Reader; 867var activityReader = reporter.ActivityItemUpdated.Reader; 894var activityReader = reporter.ActivityItemUpdated.Reader; 917var activityReader = reporter.ActivityItemUpdated.Reader; 931reporter.ActivityItemUpdated.Reader.TryRead(out _); // Clear step activity 942var activityReader = reporter.ActivityItemUpdated.Reader; 960reporter.ActivityItemUpdated.Reader.TryRead(out _); 967var activityReader = reporter.ActivityItemUpdated.Reader; 1011reporter.ActivityItemUpdated.Reader.TryRead(out _); 1012reporter.ActivityItemUpdated.Reader.TryRead(out _); 1022var activityReader = reporter.ActivityItemUpdated.Reader; 1034reporter.ActivityItemUpdated.Reader.TryRead(out _); // Clear step activity 1041var activityReader = reporter.ActivityItemUpdated.Reader; 1061var activityReader = reporter.ActivityItemUpdated.Reader; 1081var activityReader = reporter.ActivityItemUpdated.Reader; 1100var activityReader = reporter.ActivityItemUpdated.Reader; 1268while (reporter.ActivityItemUpdated.Reader.TryRead(out _)) { } 1273Assert.False(reporter.ActivityItemUpdated.Reader.TryRead(out _));