StreamUtils (Alfresco Heartbeat Data Sender 1.0.11 API)

java.lang.Object
- org.alfresco.heartbeat.datasender.internal.stream.StreamUtils

```
public class StreamUtils
extends Object
```

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method	Description
`static <T> Collector<T,List<T>,List<T>>`	`batchCollector(int batchSize, Consumer<List<T>> batchProcessor)`	Creates a new batch collector

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Method Detail
  - batchCollector
```
public static <T> Collector<T,List<T>,List<T>> batchCollector(int batchSize,
                                                                          Consumer<List<T>> batchProcessor)
```
    Creates a new batch collector
    
    Type Parameters:
    
    T - the type of elements being processed
    
    Parameters:
    
    batchSize - the batch size after which the batchProcessor is called
    
    batchProcessor - the batch processor which accepts batches of records to process
    
    Returns:
    
    a batch collector instance