From 39e1f41c0effdf193fc7581c5b673ecd242f3b66 Mon Sep 17 00:00:00 2001
From: Stefan Kalscheuer <stefan@stklcode.de>
Date: Sun, 2 Jun 2019 10:03:14 +0200
Subject: [PATCH] Add AsyncTripReader constructor with single consumer argument

---
 .../pubtrans/ura/reader/AsyncUraTripReader.java      | 12 ++++++++++++
 1 file changed, 12 insertions(+)

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<Void> future;
     private boolean cancelled;
 
+    /**
+     * Initialize trip reader.
+     *
+     * @param url      URL to read trips from.
+     * @param consumer Initial consumer.
+     */
+    public AsyncUraTripReader(URL url, Consumer<Trip> consumer) {
+        this.url = url;
+        this.consumers = new ArrayList<>();
+        this.consumers.add(consumer);
+    }
+
     /**
      * Initialize trip reader.
      *