| inBatches(int, Function) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| inBatches(int) |  | 98% | | 50% | 1 | 2 | 0 | 4 | 0 | 1 |
| PipelineBuilder(Pipe, Collection, Collection, String, ReadPipe, int, LabelledMetric, boolean, String) | | 97% | | 50% | 1 | 2 | 0 | 12 | 0 | 1 |
| thenProcessInParallel(String, Supplier, int, int) | | 100% | | 100% | 0 | 2 | 0 | 9 | 0 | 1 |
| createPipe(int, String, LabelledMetric) | | 100% | | n/a | 0 | 1 | 0 | 5 | 0 | 1 |
| addStage(Processor, int, String) | | 100% | | n/a | 0 | 1 | 0 | 6 | 0 | 1 |
| createPipelineFrom(String, Iterator, int, LabelledMetric, boolean, String) | | 100% | | n/a | 0 | 1 | 0 | 5 | 0 | 1 |
| andFinishWith(String, Consumer) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| createPipeline(String, int, LabelledMetric, boolean, String) | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
| concat(Collection, Object) | | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
| thenProcess(String, Function) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| thenProcessAsync(String, Function, int) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| thenProcessAsyncOrdered(String, Function, int) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| thenProcessInParallel(String, Function, int) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| thenFlatMap(String, Function, int) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| thenFlatMapInParallel(String, Function, int, int) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| addStage(Processor, String) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$thenFlatMapInParallel$1(Function) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$thenProcessInParallel$0(Function) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |