Package ca.uhn.fhir.util

Class TaskChunker<T>

java.lang.Object

ca.uhn.fhir.util.TaskChunker<T>

Type Parameters:

T - The type for the chunks

public class TaskChunker<T>
extends Object

This utility takes an input collection, breaks it up into chunks of a given maximum chunk size, and then passes those chunks to a consumer for processing. Use this to break up large tasks into smaller tasks.

Since:

6.6.0

Constructor Summary

Constructors

Constructor	Description
TaskChunker()

Method Summary

Modifier and Type	Method	Description
void	chunk(Collection<T> theInput, int theChunkSize, Consumer<List<T>> theBatchConsumer)
void	chunk(Iterator<T> theIterator, int theChunkSize, Consumer<List<T>> theListConsumer)
<T> Stream<List<T>>	chunk(Stream<T> theStream, int theChunkSize)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TaskChunker

public TaskChunker()

Method Details

chunk

public void chunk(Collection<T> theInput,
 int theChunkSize,
 Consumer<List<T>> theBatchConsumer)

chunk

@Nonnull
public <T> Stream<List<T>> chunk(Stream<T> theStream,
 int theChunkSize)

chunk

@Nonnull
public void chunk(Iterator<T> theIterator,
 int theChunkSize,
 Consumer<List<T>> theListConsumer)