diff --git a/base-stream-interface/src/main/java/com/telecominfraproject/wlan/stream/StreamInterface.java b/base-stream-interface/src/main/java/com/telecominfraproject/wlan/stream/StreamInterface.java
index ba533c6..7855693 100644
--- a/base-stream-interface/src/main/java/com/telecominfraproject/wlan/stream/StreamInterface.java
+++ b/base-stream-interface/src/main/java/com/telecominfraproject/wlan/stream/StreamInterface.java
@@ -1,11 +1,20 @@
 package com.telecominfraproject.wlan.stream;
 
+import java.util.List;
 
 /**
  * @author ekeddy
+ * @author dtop
  *
  */
 public interface StreamInterface<T> {
 
     void publish(T record);
+
+    default void publish(List<T> records) {
+    	if(records!=null) {
+    		records.forEach(r -> publish(r));
+    	}
+    }
+
 }