Lines Matching defs:chunks
188 * protected void process(List<Integer> chunks) {
189 * for (int number : chunks) {
338 * Sends data chunks to the {@link #process} method. This method is to be
393 * protected void process(List<Object[]> chunks) {
394 * for (Object[] row : chunks) {
401 * @param chunks intermediate results to process
407 @SuppressWarnings("varargs") // Passing chunks to add is safe
408 protected final void publish(V... chunks) {
423 doProcess.add(chunks);
427 * Receives data chunks from the {@code publish} method asynchronously on the
433 * @param chunks intermediate results to process
438 protected void process(List<V> chunks) {