Rename forEach to addListener

Author: Burak Serdar

crud/src/main/java/com/redhat/lightblue/assoc/ep/JoinSearch.java

@@ -119,7 +119,7 @@ public void close() {
         }
 
         @Override
-        public void forEach(Consumer<ResultDocument> listener) {
+        public void addListener(Consumer<ResultDocument> listener) {
             listeners.add(listener);
         }
 

crud/src/main/java/com/redhat/lightblue/assoc/ep/StepResultDocumentStream.java

@@ -37,7 +37,7 @@ public DocCtx next() {
     public void close() {}
 
     @Override
-    public void forEach(Consumer<DocCtx> listener) {
+    public void addListener(Consumer<DocCtx> listener) {
         listeners.add(listener);
     }
 }

crud/src/main/java/com/redhat/lightblue/crud/DocumentStream.java

@@ -36,7 +36,7 @@ public interface DocumentStream<T> extends Iterator<T>{
     /**
      * Adds a listener that will be called for each document of the stream when next() is called
      */
-    void forEach(Consumer<T> dest);
+    void addListener(Consumer<T> dest);
 
     static <S,D> DocumentStream<D> map(final DocumentStream<S> source,final Function<S,D> map) {
         if(source instanceof RewindableDocumentStream)
@@ -69,7 +69,7 @@ public D next() {
             return d;
         }
         @Override
-        public void forEach(Consumer<D> t) {
+        public void addListener(Consumer<D> t) {
             listeners.add(t);
         }
     }

crud/src/main/java/com/redhat/lightblue/crud/ListDocumentStream.java

@@ -66,7 +66,7 @@ public T next() {
     public void close() {}
 
     @Override
-    public void forEach(Consumer<T> listener) {
+    public void addListener(Consumer<T> listener) {
         listeners.add(listener);
     }
 }

crud/src/main/java/com/redhat/lightblue/hooks/HookManager.java

@@ -99,7 +99,7 @@ private class HookAndDocs {
         final Hook hook;
         final EntityMetadata md;
         final CRUDHook resolvedHook;
-        final List<HookDocInfo> docList=new ArrayList<>();;
+        final List<HookDocInfo> docList=new ArrayList<>();
 
         HookAndDocs(EntityMetadata md,
                     Hook hook,
@@ -279,7 +279,7 @@ private void queueHooks(CRUDOperationContext ctx, boolean mediatorHooks) {
                     addDocument(hookList,stream.next());
                 }
             } else {
-                documents.forEach(d->addDocument(hookList,d));
+                documents.addListener(d->addDocument(hookList,d));
             }
             queuedHooks.add(new QueuedHook(who,hookList));
         }        

crud/src/test/java/com/redhat/lightblue/hooks/HookManagerTest.java

@@ -366,7 +366,7 @@ public T next() {
         public void close() {}
 
         @Override
-        public void forEach(Consumer<T> listener) {
+        public void addListener(Consumer<T> listener) {
             listeners.add(listener);
         }
     }