2 implementations of IClientConnection
VBCSCompiler (1)
NamedPipeClientConnection.cs (1)
18internal sealed class NamedPipeClientConnection : IClientConnection
VBCSCompiler.UnitTests (1)
TestableClientConnection.cs (1)
17internal sealed class TestableClientConnection : IClientConnection
27 references to IClientConnection
VBCSCompiler (9)
ClientConnectionHandler.cs (4)
35Task<IClientConnection> clientConnectionTask, 51using var clientConnection = await clientConnectionTask.ConfigureAwait(false); 99private async Task<CompletionData> WriteBuildResponseAsync(IClientConnection clientConnection, Guid requestId, BuildResponse response, CompletionData completionData, CancellationToken cancellationToken) 111private async Task<CompletionData> ProcessCompilationRequestAsync(IClientConnection clientConnection, BuildRequest request, CancellationToken cancellationToken)
IClientConnection.cs (2)
47/// Returns a <see cref="Task"/> that completes when a new <see cref="IClientConnection"/> is 51Task<IClientConnection> GetNextClientConnectionAsync();
NamedPipeClientConnectionHost.cs (1)
135public async Task<IClientConnection> GetNextClientConnectionAsync()
ServerDispatcher.cs (2)
61private Task<IClientConnection>? _listenTask; 334Task<IClientConnection> clientStreamTask,
VBCSCompiler.UnitTests (18)
ClientConnectionHandlerTests.cs (6)
33var completionData = await clientConnectionHandler.ProcessAsync(Task.FromResult<IClientConnection>(clientConnection)); 51var completionData = await clientConnectionHandler.ProcessAsync(Task.FromResult<IClientConnection>(clientConnection)); 71var completionData = await clientConnectionHandler.ProcessAsync(Task.FromResult<IClientConnection>(clientConnection)); 104Task.FromResult<IClientConnection>(clientConnection), 139Task.FromResult<IClientConnection>(clientConnection), 170var task = clientConnectionHandler.ProcessAsync(Task.FromResult<IClientConnection>(clientConnection));
CompilerServerApiTest.cs (2)
74var tcs = new TaskCompletionSource<IClientConnection>(); 98return Task.FromResult<IClientConnection>(client);
NamedPipeClientConnectionHostTests.cs (2)
103var clientConnection = await _host.GetNextClientConnectionAsync(); 152using var server = await _host.GetNextClientConnectionAsync();
TestableClientConnectionHost.cs (8)
17private TaskCompletionSource<IClientConnection>? _finalTaskCompletionSource; 18private readonly Queue<Func<Task<IClientConnection>>> _waitingTasks = new Queue<Func<Task<IClientConnection>>>(); 30_finalTaskCompletionSource = new TaskCompletionSource<IClientConnection>(); 45public Task<IClientConnection> GetNextClientConnectionAsync() 47Func<Task<IClientConnection>>? func = null; 54_finalTaskCompletionSource = new TaskCompletionSource<IClientConnection>(); 66public void Add(Func<Task<IClientConnection>> func)