1 instantiation of OperationEventSubscription
Aspire.Hosting.Native.Core (1)
Diagnostics\OperationEventSource.cs (1)
23var subscription = new OperationEventSubscription(this, capacity, traceId);
14 references to OperationEventSubscription
Aspire.Hosting.Native.Core (6)
Diagnostics\OperationEventSource.cs (6)
13private readonly HashSet<OperationEventSubscription> _subscriptions = []; 16public OperationEventSubscription Subscribe(int capacity = 1024, ActivityTraceId? traceId = null) 23var subscription = new OperationEventSubscription(this, capacity, traceId); 34foreach (var subscription in _subscriptions.ToArray()) 52internal void Unsubscribe(OperationEventSubscription subscription) 66foreach (var subscription in _subscriptions)
Aspire.Hosting.Native.Core.AotSmoke (1)
tests\Aspire.Hosting.Native.Core.Tests\TestServices\DiagnosticCapture.cs (1)
15private readonly OperationEventSubscription _subscription;
Aspire.Hosting.Native.Core.Tests (6)
NativeDiagnosticChannelTests.cs (5)
15using var slow = source.Subscribe(capacity: 1); 16using var fast = source.Subscribe(capacity: 1); 33using var first = source.Subscribe(); 34using var second = source.Subscribe(); 51using var subscription = source.Subscribe();
TestServices\DiagnosticCapture.cs (1)
15private readonly OperationEventSubscription _subscription;
Aspire.Hosting.Native.Server (1)
NativeDiagnosticPump.cs (1)
11private readonly OperationEventSubscription _subscription;