diff --git a/src/main/java/teetime/stage/CollectorSink.java b/src/main/java/teetime/stage/CollectorSink.java index eb4f3a0c5cb4aba15ce875f464499e5d28af8f42..9cd33751d0d9b97db5cf991badf43a0e6cae4fea 100644 --- a/src/main/java/teetime/stage/CollectorSink.java +++ b/src/main/java/teetime/stage/CollectorSink.java @@ -45,4 +45,8 @@ public final class CollectorSink<T> extends AbstractConsumerStage<T> { this.elements.add(element); } + public List<T> getElements() { + return elements; + } + }