1 write to _responseState
Aspire.Hosting.Tests (1)
Dcp\KubernetesServiceTests.cs (1)
2548_responseState = responseState;
7 references to _responseState
Aspire.Hosting.Tests (7)
Dcp\KubernetesServiceTests.cs (7)
2558ref _responseState.SuccessfulRequestNumber, 2559Volatile.Read(ref _responseState.RequestCount) + count + 1); 2565Interlocked.Exchange(ref _responseState.ResponseDelayTicks, delay.Ticks); 2570Volatile.Write(ref _responseState.BlockWatchResponses, true); 2575return _responseState.WatchRequestArrived.Task.WaitAsync(cancellationToken); 2580while (Volatile.Read(ref _responseState.WatchRequestCount) < expectedCount) 2588return _responseState.RequestCancellationObserved.Task.WaitAsync(cancellationToken);