#296 events() first sketch

Author: amihaiemil

src/main/java/com/amihaiemil/docker/DockerSystem.java

@@ -26,6 +26,7 @@
 package com.amihaiemil.docker;
 
 import java.io.IOException;
+import java.io.Reader;
 
 /**
  * Docker System API entry point.
@@ -45,4 +46,13 @@ public interface DockerSystem {
     DiskSpaceInfo diskUsage()
         throws IOException, UnexpectedResponseException;
 
+    /**
+     * Follow the events on the server in real time.
+     * @return The events {@link Reader}.
+     * @throws IOException If an I/O error occurs.
+     * @throws UnexpectedResponseException If the API responds with an
+     *  unexpected status.
+     */
+    Reader events()
+        throws IOException, UnexpectedResponseException;
 }

src/main/java/com/amihaiemil/docker/RtDockerSystem.java

@@ -30,6 +30,7 @@
 import org.apache.http.client.methods.HttpGet;
 
 import java.io.IOException;
+import java.io.Reader;
 import java.net.URI;
 
 /**
@@ -91,4 +92,20 @@ public DiskSpaceInfo diskUsage()
         }
     }
 
+    @Override
+    public Reader events() throws IOException, UnexpectedResponseException {
+        final HttpGet monitor = new HttpGet(
+            this.baseUri.toString() + "/events"
+        );
+        return this.client.execute(
+            monitor,
+            new ReadStream(
+                new MatchStatus(
+                    monitor.getURI(),
+                    HttpStatus.SC_OK
+                )
+            )
+        );
+    }
+
 }