1 write to _responseState
Aspire.Hosting.Tests (1)
Dcp\KubernetesServiceTests.cs (1)
2437
_responseState
= responseState;
7 references to _responseState
Aspire.Hosting.Tests (7)
Dcp\KubernetesServiceTests.cs (7)
2447
ref
_responseState
.SuccessfulRequestNumber,
2448
Volatile.Read(ref
_responseState
.RequestCount) + count + 1);
2454
Interlocked.Exchange(ref
_responseState
.ResponseDelayTicks, delay.Ticks);
2459
Volatile.Write(ref
_responseState
.BlockWatchResponses, true);
2464
return
_responseState
.WatchRequestArrived.Task.WaitAsync(cancellationToken);
2469
while (Volatile.Read(ref
_responseState
.WatchRequestCount) < expectedCount)
2477
return
_responseState
.RequestCancellationObserved.Task.WaitAsync(cancellationToken);