10 writes to TransportTask
Microsoft.AspNetCore.Http.Connections (3)
Internal\HttpConnectionContext.cs (3)
424TransportTask = transport.ProcessRequestAsync(context, context.RequestAborted); 469TransportTask = Func(); 493TransportTask = longPolling.ProcessRequestAsync(nonClonedContext, tokenSource.Token);
Microsoft.AspNetCore.Http.Connections.Tests (7)
HttpConnectionManagerTests.cs (7)
87connection.TransportTask = Task.Run(async () => 105connection.TransportTask = Task.FromException<bool>(new Exception("Application failed")); 116connection.TransportTask = Task.FromResult(true); 263connection.TransportTask = Task.Run(async () => 293connection.TransportTask = tcs.Task; 316connection.TransportTask = tcs.Task; 343connection.TransportTask = tcs.Task;
12 references to TransportTask
Microsoft.AspNetCore.Http.Connections (5)
Internal\HttpConnectionContext.cs (1)
267var transportTask = TransportTask ?? Task.CompletedTask;
Internal\HttpConnectionDispatcher.cs (4)
256var resultTask = await Task.WhenAny(connection.ApplicationTask!, connection.TransportTask!); 269await ((Task)connection.TransportTask!).ConfigureAwait(ConfigureAwaitOptions.SuppressThrowing); 306if (await connection.TransportTask! 331await Task.WhenAny(connection.ApplicationTask!, connection.TransportTask!);
Microsoft.AspNetCore.Http.Connections.Tests (7)
HttpConnectionDispatcherTests.cs (6)
1500while (connection.TransportTask.IsCompleted && count < 50) 1520while (connection.TransportTask.IsCompleted && count < 50) 2089await connection.TransportTask.DefaultTimeout(); 2139await connection.TransportTask.DefaultTimeout(); 2193await connection.TransportTask.DefaultTimeout(); 2799await connection.TransportTask.DefaultTimeout();
HttpConnectionManagerTests.cs (1)
53Assert.Null(connection.TransportTask);