184public override CancellationToken RequestAborted

70context.RequestAborted = lifetime.Token;

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

42var cancellationToken = context.RequestAborted;

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);

69using var lifetime = CancellationTokenSource.CreateLinkedTokenSource(context.RequestAborted, requests.Token);

55}), context.RequestAborted); 133await context.Response.StartAsync(context.RequestAborted); 134await context.Response.Body.FlushAsync(context.RequestAborted); 138await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 140catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 206await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 215await context.Response.StartAsync(context.RequestAborted); 216await context.Response.Body.FlushAsync(context.RequestAborted); 218await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 220catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 296await context.Response.StartAsync(context.RequestAborted); 297await context.Response.Body.FlushAsync(context.RequestAborted); 301await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 303catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 310await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 359await sendRemainingEvents.Task.WaitAsync(context.RequestAborted); 371await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 373catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 421context.RequestAborted)).DefaultTimeout(); 462context.RequestAborted); 463await context.Response.Body.FlushAsync(context.RequestAborted); 467await sendResource.Task.WaitAsync(context.RequestAborted); 469await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 471catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 523context.Response.WriteAsync(line + (appendNewline ? "\n" : string.Empty), context.RequestAborted)).DefaultTimeout(); 564await firstEventReceived.Task.WaitAsync(context.RequestAborted); 569await context.Response.StartAsync(context.RequestAborted); 570await context.Response.Body.FlushAsync(context.RequestAborted); 580await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 582catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 633await context.Response.WriteAsync(partialEvent, context.RequestAborted); 639await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 641catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 681await context.Response.StartAsync(context.RequestAborted); 682await context.Response.Body.FlushAsync(context.RequestAborted); 689await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 691catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 729$$"""{"type":"MODIFIED","object":{{KubernetesJson.Serialize(container)}}}""", context.RequestAborted); 733await context.Response.StartAsync(context.RequestAborted); 734await context.Response.Body.FlushAsync(context.RequestAborted); 735await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 783await context.Response.Body.WriteAsync(bytes.AsMemory(0, split), context.RequestAborted); 784await context.Response.Body.FlushAsync(context.RequestAborted); 786await sendRemaining.Task.WaitAsync(context.RequestAborted); 787await context.Response.Body.WriteAsync(bytes.AsMemory(split), context.RequestAborted); 788await context.Response.Body.FlushAsync(context.RequestAborted); 789await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 854context.RequestAborted); 859await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 861catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 913context.RequestAborted); 947$$"""{"type":"MODIFIED","object":{{KubernetesJson.Serialize(container)}}}""" + "\n", context.RequestAborted); 948await context.Response.Body.FlushAsync(context.RequestAborted); 992await Task.Delay(TimeSpan.FromMilliseconds(500), context.RequestAborted); 1236await context.Response.WriteAsync(errorBody, context.RequestAborted); 1369await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 1371catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 1467await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 1469catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 1735await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 1737catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 1797await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 1799catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 1922var responseDelay = Task.Delay(TimeSpan.FromSeconds(3), timeProvider, context.RequestAborted); 1928await context.Response.WriteAsync("""{"apiVersion":"usvc-dev.developer.microsoft.com/v1","kind":"ContainerList","items":[]}""", context.RequestAborted); 1930catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 1979var responseDelay = Task.Delay(TimeSpan.FromSeconds(3), timeProvider, context.RequestAborted); 1984catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 2105await Task.Delay(TimeSpan.FromSeconds(1), context.RequestAborted); 2107await context.Response.WriteAsync("""{"apiVersion":"usvc-dev.developer.microsoft.com/v1","kind":"ContainerList","items":[]}""", context.RequestAborted); 2109catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 2216context.RequestAborted); 2217await context.Response.Body.FlushAsync(context.RequestAborted); 2220await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 2222catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 2264await context.Response.WriteAsync("first\n", context.RequestAborted); 2265await context.Response.Body.FlushAsync(context.RequestAborted); 2266await continueStream.Task.WaitAsync(context.RequestAborted); 2267await context.Response.WriteAsync("second\n", context.RequestAborted); 2385return KubernetesJson.Deserialize<Container>(await reader.ReadToEndAsync(context.RequestAborted)); 2392return context.Response.WriteAsync(KubernetesJson.Serialize(container), context.RequestAborted); 2403context.RequestAborted); 2632await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 2634catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested) 2646await Task.Delay(TimeSpan.FromTicks(responseDelayTicks), context.RequestAborted); 2648catch (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;

796TransportTask = transport.ProcessRequestAsync(context, context.RequestAborted); 856var 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); 375&& !context.HttpContext.RequestAborted.IsCancellationRequested)

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

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

63context.RequestAborted,

311public 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

93context.RequestAborted); 98await response.Content.CopyToAsync(context.Response.Body, context.RequestAborted); 128context.RequestAborted); 154using var cancellationSource = CancellationTokenSource.CreateLinkedTokenSource(context.RequestAborted, _applicationStopping);

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

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

233await context.Response.WriteAsync("{ \"hotReload\": true }", context.RequestAborted); 291await InitializeBrowserConnectionAsync(connection, context.RequestAborted);

174context.RequestAborted); 192await Task.Delay(Timeout.InfiniteTimeSpan, context.RequestAborted); 194catch (OperationCanceledException) when (context.RequestAborted.IsCancellationRequested)