184public override CancellationToken RequestAborted

106context.RequestAborted = linkedCts.Token; 132context.RequestAborted = originalToken;

76using var attachment = CancellationTokenSource.CreateLinkedTokenSource(context.RequestAborted); 84catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 132using var timeout = CancellationTokenSource.CreateLinkedTokenSource(context.RequestAborted); 136catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 243using var handshake = CancellationTokenSource.CreateLinkedTokenSource(context.RequestAborted); 247catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 269await BridgeAsync(socket, workload, upstream, session, logger, context.RequestAborted).ConfigureAwait(false);

55}), context.RequestAborted); 92await context.Response.StartAsync(context.RequestAborted); 93await context.Response.Body.FlushAsync(context.RequestAborted); 97await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 99catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 165await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 174await context.Response.StartAsync(context.RequestAborted); 175await context.Response.Body.FlushAsync(context.RequestAborted); 177await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 179catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 255await context.Response.StartAsync(context.RequestAborted); 256await context.Response.Body.FlushAsync(context.RequestAborted); 260await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 262catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 269await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 318await sendRemainingEvents.Task.WaitAsync(context.RequestAborted); 330await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 332catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 380context.RequestAborted)).DefaultTimeout(); 421context.RequestAborted); 422await context.Response.Body.FlushAsync(context.RequestAborted); 426await sendResource.Task.WaitAsync(context.RequestAborted); 428await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 430catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 482context.Response.WriteAsync(line + (appendNewline ? "\n" : string.Empty), context.RequestAborted)).DefaultTimeout(); 522await context.Response.WriteAsync(partialEvent, context.RequestAborted); 528await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 530catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 570await context.Response.StartAsync(context.RequestAborted); 571await context.Response.Body.FlushAsync(context.RequestAborted); 578await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 580catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 618$$"""{"type":"MODIFIED","object":{{KubernetesJson.Serialize(container)}}}""", context.RequestAborted); 622await context.Response.StartAsync(context.RequestAborted); 623await context.Response.Body.FlushAsync(context.RequestAborted); 624await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 672await context.Response.Body.WriteAsync(bytes.AsMemory(0, split), context.RequestAborted); 673await context.Response.Body.FlushAsync(context.RequestAborted); 675await sendRemaining.Task.WaitAsync(context.RequestAborted); 676await context.Response.Body.WriteAsync(bytes.AsMemory(split), context.RequestAborted); 677await context.Response.Body.FlushAsync(context.RequestAborted); 678await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 743context.RequestAborted); 748await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 750catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 802context.RequestAborted); 836$$"""{"type":"MODIFIED","object":{{KubernetesJson.Serialize(container)}}}""" + "\n", context.RequestAborted); 837await context.Response.Body.FlushAsync(context.RequestAborted); 881await Task.Delay(TimeSpan.FromMilliseconds(500), context.RequestAborted); 1125await context.Response.WriteAsync(errorBody, context.RequestAborted); 1258await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 1260catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 1356await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 1358catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 1624await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 1626catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 1686await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 1688catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 1811var responseDelay = Task.Delay(TimeSpan.FromSeconds(3), timeProvider, context.RequestAborted); 1817await context.Response.WriteAsync("""{"apiVersion":"usvc-dev.developer.microsoft.com/v1","kind":"ContainerList","items":[]}""", context.RequestAborted); 1819catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 1868var responseDelay = Task.Delay(TimeSpan.FromSeconds(3), timeProvider, context.RequestAborted); 1873catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 1994await Task.Delay(TimeSpan.FromSeconds(1), context.RequestAborted); 1996await context.Response.WriteAsync("""{"apiVersion":"usvc-dev.developer.microsoft.com/v1","kind":"ContainerList","items":[]}""", context.RequestAborted); 1998catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 2105context.RequestAborted); 2106await context.Response.Body.FlushAsync(context.RequestAborted); 2109await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 2111catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 2153await context.Response.WriteAsync("first\n", context.RequestAborted); 2154await context.Response.Body.FlushAsync(context.RequestAborted); 2155await continueStream.Task.WaitAsync(context.RequestAborted); 2156await context.Response.WriteAsync("second\n", context.RequestAborted); 2274return KubernetesJson.Deserialize<Container>(await reader.ReadToEndAsync(context.RequestAborted)); 2281return context.Response.WriteAsync(KubernetesJson.Serialize(container), context.RequestAborted); 2292context.RequestAborted); 2521await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 2523catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 2535await Task.Delay(TimeSpan.FromTicks(responseDelayTicks), context.RequestAborted); 2537catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested)

173ticket = await Options.SessionStore.RetrieveAsync(claim.Value, Context, Context.RequestAborted); 188await Options.SessionStore.RemoveAsync(_sessionKey!, Context, Context.RequestAborted); 265await Options.SessionStore.RenewAsync(_sessionKey, ticket, Context, Context.RequestAborted); 343await Options.SessionStore.RenewAsync(_sessionKey, ticket, Context, Context.RequestAborted); 347_sessionKey = await Options.SessionStore.StoreAsync(ticket, Context, Context.RequestAborted); 393await Options.SessionStore.RemoveAsync(_sessionKey, Context, Context.RequestAborted);

52var response = await Backchannel.GetAsync(endpoint, Context.RequestAborted); 58using (var payload = JsonDocument.Parse(await response.Content.ReadAsStringAsync(Context.RequestAborted)))

50var response = await Backchannel.SendAsync(request, Context.RequestAborted); 56using (var payload = JsonDocument.Parse(await response.Content.ReadAsStringAsync(Context.RequestAborted)))

253var configuration = await Options.ConfigurationManager.GetConfigurationAsync(Context.RequestAborted);

46var response = await Backchannel.SendAsync(request, Context.RequestAborted); 52using (var payload = JsonDocument.Parse(await response.Content.ReadAsStringAsync(Context.RequestAborted)))

222var response = await Backchannel.SendAsync(requestMessage, Context.RequestAborted); 223var body = await response.Content.ReadAsStringAsync(Context.RequestAborted);

132var form = await Request.ReadFormAsync(Context.RequestAborted); 232_configuration = await Options.ConfigurationManager.GetConfigurationAsync(Context.RequestAborted); 404_configuration = await Options.ConfigurationManager.GetConfigurationAsync(Context.RequestAborted); 604var parResponseMessage = await Backchannel.SendAsync(requestMessage, Context.RequestAborted); 623var parResponseString = await parResponseMessage.Content.ReadAsStringAsync(Context.RequestAborted); 671var form = await Request.ReadFormAsync(Context.RequestAborted); 760_configuration = await Options.ConfigurationManager.GetConfigurationAsync(Context.RequestAborted); 1000var responseMessage = await Backchannel.SendAsync(requestMessage, Context.RequestAborted); 1022var responseContent = await responseMessage.Content.ReadAsStringAsync(Context.RequestAborted); 1066var responseMessage = await Backchannel.SendAsync(requestMessage, Context.RequestAborted); 1068var userInfoResponse = await responseMessage.Content.ReadAsStringAsync(Context.RequestAborted);

267return await Backchannel.SendAsync(request, Context.RequestAborted); 276var responseText = await response.Content.ReadAsStringAsync(Context.RequestAborted); 308var responseText = await response.Content.ReadAsStringAsync(Context.RequestAborted); 332var responseText = await response.Content.ReadAsStringAsync(Context.RequestAborted); 371var errorContentStream = await response.Content.ReadAsStreamAsync(Context.RequestAborted);

89_configuration = await Options.ConfigurationManager.GetConfigurationAsync(Context.RequestAborted); 160var form = await Request.ReadFormAsync(Context.RequestAborted); 386_configuration = await Options.ConfigurationManager.GetConfigurationAsync(Context.RequestAborted); 422_configuration = await Options.ConfigurationManager.GetConfigurationAsync(Context.RequestAborted);

51return context.Response.WriteAsync(DisabledResponse, context.RequestAborted);

116await ResolveOrBeginCreateAsync(cacheView, state, resolution, httpContext.RequestAborted);

120if ((ex is OperationCanceledException || ex is IOException) && context.RequestAborted.IsCancellationRequested)

117if ((edi.SourceException is OperationCanceledException || edi.SourceException is IOException) && context.RequestAborted.IsCancellationRequested) 181if (await exceptionHandler.TryHandleAsync(context, edi.SourceException, context.RequestAborted))

46var result = await _healthCheckService.CheckHealthAsync(_healthCheckOptions.Predicate, httpContext.RequestAborted);

170protected override CancellationToken CancellationTokenCore => HttpContext.RequestAborted;

89if (context.RequestAborted.IsCancellationRequested) 98var originalToken = context.RequestAborted;

98public CancellationToken RequestAborted => _context.RequestAborted;

794TransportTask = transport.ProcessRequestAsync(context, context.RequestAborted); 854var tokenSource = CancellationTokenSource.CreateLinkedTokenSource(Cancellation.Token, nonClonedContext.RequestAborted, timeoutSource.Token);

75if (context.RequestAborted.IsCancellationRequested)

96return WriteAsJsonAsyncSlow(response.BodyWriter, value, options, response.HttpContext.RequestAborted); 127return WriteAsJsonAsyncSlow(response, value, jsonTypeInfo, response.HttpContext.RequestAborted); 169return WriteAsJsonAsyncSlow(response, value, jsonTypeInfo, response.HttpContext.RequestAborted); 276response.HttpContext.RequestAborted); 326return WriteAsJsonAsyncSlow(response.BodyWriter, value, type, context, response.HttpContext.RequestAborted);

95private static readonly MemberExpression RequestAbortedExpr = Expression.Property(HttpContextExpr, typeof(HttpContext).GetProperty(nameof(HttpContext.RequestAborted))!);

93var localCancel = useRequestAborted ? response.HttpContext.RequestAborted : cancellationToken; 115var localCancel = useRequestAborted ? response.HttpContext.RequestAborted : cancellationToken;

57await SseFormatter.WriteAsync(stringEvents, httpContext.Response.Body, httpContext.RequestAborted); 63httpContext.RequestAborted);

39await StreamCopyOperation.CopyToAsync(fileStream, outputStream, count: null, bufferSize: 64 * 1024, cancel: context.RequestAborted); 44await StreamCopyOperation.CopyToAsync(fileStream, outputStream, rangeLength, BufferSize, context.RequestAborted); 64await outputStream.WriteAsync(buffer, context.RequestAborted); 78await outputStream.WriteAsync(buffer.Slice(from, length), context.RequestAborted);

34_cancel = contextAccessor?.HttpContext?.RequestAborted ?? CancellationToken.None;

42_cancel = services?.GetService<IHttpContextAccessor>()?.HttpContext?.RequestAborted ?? CancellationToken.None;

100passwordHash = await userPasswordStore.GetPasswordHashAsync(user, HttpContext.RequestAborted);

100passwordHash = await userPasswordStore.GetPasswordHashAsync(user, HttpContext.RequestAborted);

94await JsonSerializer.SerializeAsync(responseWriter, context.Object, jsonTypeInfo, httpContext.RequestAborted); 98await JsonSerializer.SerializeAsync(responseWriter, context.Object, SerializerOptions, httpContext.RequestAborted); 101catch (OperationCanceledException) when (context.HttpContext.RequestAborted.IsCancellationRequested) { }

69await JsonSerializer.SerializeAsync(responseWriter, value, objectType, jsonSerializerOptions, context.HttpContext.RequestAborted); 71catch (OperationCanceledException) when (context.HttpContext.RequestAborted.IsCancellationRequested) { } 82await JsonSerializer.SerializeAsync(transcodingStream, value, objectType, jsonSerializerOptions, context.HttpContext.RequestAborted); 83await transcodingStream.FlushAsync(context.HttpContext.RequestAborted); 85catch (OperationCanceledException) when (context.HttpContext.RequestAborted.IsCancellationRequested)

24var model = (object)bindingContext.HttpContext.RequestAborted;

39await StreamCopyOperation.CopyToAsync(fileStream, outputStream, count: null, bufferSize: 64 * 1024, cancel: context.RequestAborted); 44await StreamCopyOperation.CopyToAsync(fileStream, outputStream, rangeLength, BufferSize, context.RequestAborted); 64await outputStream.WriteAsync(buffer, context.RequestAborted); 78await outputStream.WriteAsync(buffer.Slice(from, length), context.RequestAborted);

234value = await reader(value, context.HttpContext.RequestAborted); 236if (context.HttpContext.RequestAborted.IsCancellationRequested)

212value = await reader(value, context.HttpContext.RequestAborted); 214if (context.HttpContext.RequestAborted.IsCancellationRequested)

159value = await reader(value, context.HttpContext.RequestAborted); 161catch (OperationCanceledException) when (context.HttpContext.RequestAborted.IsCancellationRequested) { } 163if (context.HttpContext.RequestAborted.IsCancellationRequested)

110value = await reader(value, context.HttpContext.RequestAborted); 112catch (OperationCanceledException) when (context.HttpContext.RequestAborted.IsCancellationRequested) { } 113if (context.HttpContext.RequestAborted.IsCancellationRequested)

57var document = await documentService.GetOpenApiDocumentAsync(context.RequestServices, context.Request, context.RequestAborted); 80await document.SerializeAsync(openApiWriter, documentOptions.OpenApiVersion, context.RequestAborted); 81await context.Response.BodyWriter.FlushAsync(context.RequestAborted);

110await policy.CacheRequestAsync(context, httpContext.RequestAborted); 179await policy.ServeResponseAsync(context, httpContext.RequestAborted); 276await policy.ServeFromCacheAsync(context, context.HttpContext.RequestAborted); 318await context.CachedResponse.CopyToAsync(response.BodyWriter, context.HttpContext.RequestAborted); 348cacheEntry = await _outputCacheEntryDispatcher.ScheduleAsync(cacheContext.CacheKey, (Store: _store, CacheContext: cacheContext), static async (key, state) => await OutputCacheEntryFormatter.GetAsync(key, state.Store, state.CacheContext.HttpContext.RequestAborted)); 424&& !context.HttpContext.RequestAborted.IsCancellationRequested) 448_store, _logger, context.HttpContext.RequestAborted);

336if (!await r(c, c.HttpContext.RequestAborted))

146await thisRequestOnRejected(new OnRejectedContext() { HttpContext = context, Lease = leaseContext.Lease! }, context.RequestAborted); 159var waitTask = CombinedWaitAsync(context, context.RequestAborted); 237if (ex is OperationCanceledException && context.RequestAborted.IsCancellationRequested)

189await body.CopyToAsync(response.BodyWriter, context.HttpContext.RequestAborted);

76await entry.Parameter.ValidateAsync(argument, validateContext, context.HttpContext.RequestAborted);

56if (!await _spaProxyLaunchManager.IsSpaProxyRunning(context.RequestAborted))

63context.RequestAborted,

280public CancellationToken CancellationToken => _context.RequestAborted;

356await _context.Response.SendFileAsync(_fileInfo, 0, _length, _context.RequestAborted); 389await _context.Response.SendFileAsync(_fileInfo, start, length, _context.RequestAborted);

146await _httpContext.Response.Body.FlushAsync(_httpContext.RequestAborted); // Send headers to the client

90context.RequestAborted); 95await response.Content.CopyToAsync(context.Response.Body, context.RequestAborted); 125context.RequestAborted); 150using var cancellationSource = CancellationTokenSource.CreateLinkedTokenSource(context.RequestAborted);

65return context.Response.WriteAsync("[]", context.RequestAborted);

297_socketConnectionManager.AddSocketConnection(webSocket, socketTcs, context.GetDcpId(), context.RequestAborted);

273await InitializeBrowserConnectionAsync(connection, context.RequestAborted);

44await context.Response.WriteAsync("{ \"hotReload\": true }", context.RequestAborted);

165await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 167catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested)