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)
56Debug.Assert(_queue is null); 73var task = Task.Run(() => ListenCoreAsync(PipeName, Logger, _queue, _cancellationTokenSource.Token)); 86Debug.Assert(_queue is object); 118_queue.Complete(); 119_queue.WhenCompletedTask.Wait(); 123while (_queue.TryDequeue(out var connectionResult)) 143Debug.Assert(_queue is object); 145var listenResult = await _queue.DequeueAsync(_cancellationTokenSource.Token).ConfigureAwait(false);