Added deleteUserData method to Harness Client

Author: qqmbr4k

example/src/main/java/HarnessClientExample.java

@@ -61,10 +61,15 @@ public static void main(String[] args) {
         HarnessClient client = new HarnessClient(engineId, serverHost, serverPort, optionalCreds);
 
         runGetUserData(client, "u1");
+//        runDeleteUserData(client, "u1");
     }
 
 
     private static void runGetUserData(HarnessClient client, String userId) {
-        client.getEvents(userId).thenApply(x -> { System.out.println(x); return new Object(); });
+        client.deleteEvents(userId).thenAccept(System.out::println);
+    }
+
+    private static void runDeleteUserData(HarnessClient client, String userId) {
+        client.deleteEvents(userId).thenAccept(System.out::println);
     }
 }

src/main/java/com/actionml/HarnessClient.java

@@ -55,5 +55,17 @@ public CompletionStage<Pair<Integer, List<String>>> getEvents(String userId) {
         );
     }
 
+    public CompletionStage<Integer> deleteEvents(String userId) {
+        return withAuth().thenCompose(optionalToken ->
+                Source.single(this.uri.addPathSegment(userId))
+                        .map(this::createDelete)
+                        .zipWithIndex()
+                        .map(pair -> pair.copy(pair.first(), (Long) pair.second()))
+                        .via(this.poolClientFlow)
+                        .mapAsync(1, this::extractResponse)
+                        .runFold(0, (a, i) -> i.second().status().intValue(), this.materializer)
+        );
+    }
+
 
 }