35 instantiations of AsyncQueue
Microsoft.CodeAnalysis (8)
DiagnosticAnalyzer\AnalyzerDriver.cs (1)
846.WithEventQueue(new AsyncQueue<CompilationEvent>());
DiagnosticAnalyzer\CompilationWithAnalyzers.cs (5)
44private static readonly AsyncQueue<CompilationEvent> s_EmptyEventQueue = new AsyncQueue<CompilationEvent>(); 101.WithEventQueue(new AsyncQueue<CompilationEvent>()); 305var compilation = _compilation.WithEventQueue(new AsyncQueue<CompilationEvent>()); 726: _compilation.WithSemanticModelProvider(CachingSemanticModelProvider.Instance).WithEventQueue(new AsyncQueue<CompilationEvent>()); 1141var eventQueue = new AsyncQueue<CompilationEvent>();
DiagnosticAnalyzer\DiagnosticQueue.cs (2)
44_queue = new AsyncQueue<Diagnostic>(); 49_queue = new AsyncQueue<Diagnostic>();
Microsoft.CodeAnalysis.CSharp.Emit3.UnitTests (12)
Diagnostics\CompilationEventTests.cs (5)
94var q = new AsyncQueue<CompilationEvent>(); 148var q = new AsyncQueue<CompilationEvent>(); 153q = new AsyncQueue<CompilationEvent>(); 163q = new AsyncQueue<CompilationEvent>(); 173q = new AsyncQueue<CompilationEvent>();
Diagnostics\GetDiagnosticsTests.cs (7)
168var eventQueue = new AsyncQueue<CompilationEvent>(); 217var eventQueue = new AsyncQueue<CompilationEvent>(); 269var eventQueue = new AsyncQueue<CompilationEvent>(); 336var eventQueue = new AsyncQueue<CompilationEvent>(); 402var eventQueue = new AsyncQueue<CompilationEvent>(); 444var eventQueue = new AsyncQueue<CompilationEvent>(); 499var compilation = CreateCompilationWithMscorlib461(CSharpTestSource.None).WithEventQueue(new AsyncQueue<CompilationEvent>());
Microsoft.CodeAnalysis.UnitTests (14)
AsyncQueueTests.cs (14)
26var queue = new AsyncQueue<int>(); 36var queue = new AsyncQueue<int>(); 44var queue = new AsyncQueue<int>(); 53var queue = new AsyncQueue<int>(); 65var queue = new AsyncQueue<int>(); 75var queue = new AsyncQueue<int>(); 96var queue = new AsyncQueue<int>(); 117var queue = new AsyncQueue<int>(); 144var queue = new AsyncQueue<int>(); 165var queue = new AsyncQueue<int>(); 177var queue = new AsyncQueue<int>(); 194var queue = new AsyncQueue<int>(); 206var queue = new AsyncQueue<int>(); 221var queue = new AsyncQueue<int>();
VBCSCompiler (1)
src\Compilers\Server\VBCSCompiler\NamedPipeClientConnectionHost.cs (1)
60_queue = new AsyncQueue<ListenResult>();
48 references to AsyncQueue
Microsoft.CodeAnalysis (16)
Compilation\Compilation.cs (3)
82AsyncQueue<CompilationEvent>? eventQueue) 300internal abstract Compilation WithEventQueue(AsyncQueue<CompilationEvent>? eventQueue); 650internal AsyncQueue<CompilationEvent>? EventQueue { get; }
DiagnosticAnalyzer\AnalyzerDriver.cs (6)
26/// It uses a <see cref="AsyncQueue{TElement}"/> of <see cref="CompilationEvent"/>s to drive its analysis. 334private AsyncQueue<CompilationEvent>? _lazyCompilationEventQueue; 339public AsyncQueue<CompilationEvent> CompilationEventQueue 633internal async Task AttachQueueAndProcessAllEventsAsync(AsyncQueue<CompilationEvent> eventQueue, AnalysisScope analysisScope, CancellationToken cancellationToken) 662internal void AttachQueueAndStartProcessingEvents(AsyncQueue<CompilationEvent> eventQueue, AnalysisScope analysisScope, bool usingPrePopulatedEventQueue, CancellationToken cancellationToken) 2399/// It uses a <see cref="AsyncQueue{TElement}"/> of <see cref="CompilationEvent"/>s to drive its analysis.
DiagnosticAnalyzer\AsyncQueue.cs (1)
163/// Same operation as <see cref="AsyncQueue{TElement}.Complete"/> except it will not
DiagnosticAnalyzer\CompilationWithAnalyzers.cs (5)
44private static readonly AsyncQueue<CompilationEvent> s_EmptyEventQueue = new AsyncQueue<CompilationEvent>(); 823var eventQueue = CreateEventsQueue(compilationEvents); 1048var eventQueue = compilation.EventQueue!; 1134private static AsyncQueue<CompilationEvent> CreateEventsQueue(ImmutableArray<CompilationEvent> compilationEvents) 1141var eventQueue = new AsyncQueue<CompilationEvent>();
DiagnosticAnalyzer\DiagnosticQueue.cs (1)
40private readonly AsyncQueue<Diagnostic> _queue;
Microsoft.CodeAnalysis.CSharp (3)
Compilation\CSharpCompilation.cs (3)
463AsyncQueue<CompilationEvent>? eventQueue = null) 481AsyncQueue<CompilationEvent>? eventQueue = null) 743internal override Compilation WithEventQueue(AsyncQueue<CompilationEvent>? eventQueue)
Microsoft.CodeAnalysis.CSharp.Emit3.UnitTests (12)
Diagnostics\CompilationEventTests.cs (4)
18internal static void VerifyEvents(AsyncQueue<CompilationEvent> queue, params string[] expectedEvents) 94var q = new AsyncQueue<CompilationEvent>(); 111private static void VerifyEvents(AsyncQueue<CompilationEvent> q) 148var q = new AsyncQueue<CompilationEvent>();
Diagnostics\GetDiagnosticsTests.cs (8)
168var eventQueue = new AsyncQueue<CompilationEvent>(); 217var eventQueue = new AsyncQueue<CompilationEvent>(); 269var eventQueue = new AsyncQueue<CompilationEvent>(); 336var eventQueue = new AsyncQueue<CompilationEvent>(); 402var eventQueue = new AsyncQueue<CompilationEvent>(); 444var eventQueue = new AsyncQueue<CompilationEvent>(); 451private static bool DequeueCompilationEvents(AsyncQueue<CompilationEvent> eventQueue, out bool compilationStartedFired, out HashSet<string> declaredSymbolNames, out HashSet<string> declaredSymbols, out HashSet<string> completedCompilationUnits) 916var eventQueue = compilationWithAnalyzers.Compilation.EventQueue;
Microsoft.CodeAnalysis.UnitTests (15)
AsyncQueueTests.cs (15)
26var queue = new AsyncQueue<int>(); 36var queue = new AsyncQueue<int>(); 44var queue = new AsyncQueue<int>(); 53var queue = new AsyncQueue<int>(); 65var queue = new AsyncQueue<int>(); 75var queue = new AsyncQueue<int>(); 96var queue = new AsyncQueue<int>(); 117var queue = new AsyncQueue<int>(); 144var queue = new AsyncQueue<int>(); 165var queue = new AsyncQueue<int>(); 177var queue = new AsyncQueue<int>(); 194var queue = new AsyncQueue<int>(); 206var queue = new AsyncQueue<int>(); 216/// after the <see cref="AsyncQueue{TElement}"/> is completed. 221var queue = new AsyncQueue<int>();
VBCSCompiler (2)
src\Compilers\Server\VBCSCompiler\NamedPipeClientConnectionHost.cs (2)
35private AsyncQueue<ListenResult>? _queue; 170AsyncQueue<ListenResult> queue,