1 write to _responseState
Aspire.Hosting.Tests (1)
Dcp\KubernetesServiceTests.cs (1)
404
_responseState
= responseState;
7 references to _responseState
Aspire.Hosting.Tests (7)
Dcp\KubernetesServiceTests.cs (7)
414
ref
_responseState
.SuccessfulRequestNumber,
415
Volatile.Read(ref
_responseState
.RequestCount) + count + 1);
421
Interlocked.Exchange(ref
_responseState
.ResponseDelayTicks, delay.Ticks);
426
Volatile.Write(ref
_responseState
.BlockWatchResponses, true);
431
return
_responseState
.WatchRequestArrived.Task.WaitAsync(cancellationToken);
436
while (Volatile.Read(ref
_responseState
.WatchRequestCount) < expectedCount)
444
return
_responseState
.RequestCancellationObserved.Task.WaitAsync(cancellationToken);