From 68e5ad4a7e1dfa737d8a58fff2e1382cc87a10bd Mon Sep 17 00:00:00 2001
From: Andy Flury <aflury@algotrader.ch>
Date: Thu, 9 Feb 2017 17:13:32 +0100
Subject: [PATCH 1/2] handle end-of-streaming

---
 src/main/java/org/influxdb/impl/InfluxDBImpl.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/main/java/org/influxdb/impl/InfluxDBImpl.java b/src/main/java/org/influxdb/impl/InfluxDBImpl.java
index 293909fcb..8cc047e40 100644
--- a/src/main/java/org/influxdb/impl/InfluxDBImpl.java
+++ b/src/main/java/org/influxdb/impl/InfluxDBImpl.java
@@ -367,7 +367,9 @@ public void onResponse(final Call<ResponseBody> call, final Response<ResponseBod
                         throw new RuntimeException(errorBody.string());
                     }
                 } catch (EOFException e) {
-                    // do nothing
+                    QueryResult queryResult = new QueryResult();
+                    queryResult.setError("DONE");
+                    consumer.accept(queryResult);
                 } catch (IOException e) {
                     throw new RuntimeException(e);
                 }

From 854f10147c4cbf7e53dd69b3044950ca5b90560a Mon Sep 17 00:00:00 2001
From: Andy Flury <aflury@algotrader.ch>
Date: Thu, 9 Feb 2017 17:24:27 +0100
Subject: [PATCH 2/2] update test case

---
 src/test/java/org/influxdb/InfluxDBTest.java | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/src/test/java/org/influxdb/InfluxDBTest.java b/src/test/java/org/influxdb/InfluxDBTest.java
index 132df79ac..5448a7691 100644
--- a/src/test/java/org/influxdb/InfluxDBTest.java
+++ b/src/test/java/org/influxdb/InfluxDBTest.java
@@ -556,6 +556,11 @@ public void accept(QueryResult result) {
         Assert.assertNotNull(result);
         System.out.println(result);
         Assert.assertEquals(1, result.getResults().get(0).getSeries().get(0).getValues().size());
+
+        result = queue.poll(20, TimeUnit.SECONDS);
+        Assert.assertNotNull(result);
+        System.out.println(result);
+        Assert.assertEquals("DONE", result.getError());
     }
 
     /**