26 references to Chunk
aspire (1)
Documentation\ApiDocs\ApiDocsIndexService.cs (1)
493foreach (var candidateContainerIds in GetCandidateMemberContainerIds(routeResults, queryTokens, normalizedLanguage).Chunk(MemberSearchBatchSize))
Aspire.Cli.Tests (1)
Agents\TelemetryHookScriptTests.cs (1)
551static KeyValuePair<string, string>[] Tags(string[] args) => args.Skip(2).Chunk(2)
Aspire.Dashboard (22)
Otlp\Storage\SqliteTelemetryRepository.Caching.cs (1)
364foreach (var batch in pendingMetrics.Take(availableCount).Chunk(MaxInstrumentBatchSize))
Otlp\Storage\SqliteTelemetryRepository.Logs.cs (2)
170foreach (var batch in resourcesToUpdate.Chunk(MaxLogAttributeBatchSize)) 686foreach (var logIdBatch in logIds.Chunk(MaxLogAttributeReadBatchSize))
Otlp\Storage\SqliteTelemetryRepository.Metrics.Reads.cs (1)
558foreach (var exemplarIdBatch in exemplarIds.Chunk(MaxMetricReadBatchSize))
Otlp\Storage\SqliteTelemetryRepository.Metrics.Writes.cs (2)
341.SelectMany(static group => group.Chunk(MaxMetricPointBatchSize))) 788foreach (var batch in exemplars.Values.Chunk(MaxMetricPointBatchSize))
Otlp\Storage\SqliteTelemetryRepository.Resources.cs (1)
57foreach (var traceBatch in affectedTraceIds.Chunk(MaxTraceBatchSize))
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (2)
347foreach (var identityBatch in spanIdentities.Chunk(MaxSpanDetailBatchSize)) 384foreach (var logIdBatch in logIds.Chunk(MaxLogAttributeReadBatchSize))
Otlp\Storage\SqliteTelemetryRepository.Traces.Reads.cs (3)
42foreach (var batch in records.Chunk(MaxTraceBatchSize)) 754foreach (var eventIdBatch in eventRecords.Select(record => record.EventId).Chunk(MaxSpanDetailBatchSize)) 778foreach (var linkIdBatch in linkRecords.Select(record => record.LinkId).Chunk(MaxSpanDetailBatchSize))
Otlp\Storage\SqliteTelemetryRepository.Traces.Writes.cs (10)
138foreach (var batch in traceIds.Chunk(MaxTraceBatchSize)) 186foreach (var traceBatch in existingTraces.Keys.Chunk(MaxTraceBatchSize)) 197foreach (var spanIdBatch in relevantSpanIds.Chunk(MaxSpanDetailBatchSize)) 220.Chunk(MaxSpanDetailBatchSize)) 242.Chunk(MaxSpanDetailBatchSize)) 361.Chunk(MaxTraceBatchSize)) 527foreach (var batch in resourcesToUpdate.Chunk(MaxTraceBatchSize)) 613foreach (var batch in spanUpdates.Chunk(MaxSpanDetailBatchSize)) 699foreach (var deltaBatch in deltas.Chunk(MaxSpanDetailBatchSize)) 723foreach (var deltaBatch in deltas.Chunk(MaxSpanDetailBatchSize))
Aspire.Hosting.Tests (1)
Terminals\Hex1bAspireTerminalTests.cs (1)
375Assert.Equal(string.Join('\n', main.Chunk(20).Select(chunk => new string(chunk).PadRight(20)).Append("ready")),
Microsoft.CodeAnalysis.Workspaces (1)
Workspace\Solution\SolutionCompilationState.RegularCompilationTracker.cs (1)
327foreach (var chunk in this.ProjectState.DocumentStates.GetStatesInCompilationOrder().Chunk(TranslationAction.AddDocumentsAction.AddDocumentsBatchSize))