diff --git a/src/main/java/de/stklcode/pubtrans/ura/reader/AsyncUraTripReader.java b/src/main/java/de/stklcode/pubtrans/ura/reader/AsyncUraTripReader.java index c1a37dd..cb2cdde 100644 --- a/src/main/java/de/stklcode/pubtrans/ura/reader/AsyncUraTripReader.java +++ b/src/main/java/de/stklcode/pubtrans/ura/reader/AsyncUraTripReader.java @@ -46,6 +46,18 @@ public class AsyncUraTripReader implements AutoCloseable { private CompletableFuture future; private boolean cancelled; + /** + * Initialize trip reader. + * + * @param url URL to read trips from. + * @param consumer Initial consumer. + */ + public AsyncUraTripReader(URL url, Consumer consumer) { + this.url = url; + this.consumers = new ArrayList<>(); + this.consumers.add(consumer); + } + /** * Initialize trip reader. *