2 writes to _queue
VBCSCompiler (2)
src\Compilers\Server\VBCSCompiler\NamedPipeClientConnectionHost.cs (2)
60
_queue
= new AsyncQueue<ListenResult>();
128
_queue
= null;
8 references to _queue
VBCSCompiler (8)
src\Compilers\Server\VBCSCompiler\NamedPipeClientConnectionHost.cs (8)
56
Debug.Assert(
_queue
is null);
73
var task = Task.Run(() => ListenCoreAsync(PipeName, Logger,
_queue
, _cancellationTokenSource.Token));
86
Debug.Assert(
_queue
is object);
118
_queue
.Complete();
119
_queue
.WhenCompletedTask.Wait();
123
while (
_queue
.TryDequeue(out var connectionResult))
143
Debug.Assert(
_queue
is object);
145
var listenResult = await
_queue
.DequeueAsync(_cancellationTokenSource.Token).ConfigureAwait(false);