From 1730ffdcbff5f2af72537dd4770e342f909e48fb Mon Sep 17 00:00:00 2001
From: Dmitry Toptygin <dmitry.toptygin@connectus.ai>
Date: Wed, 3 Jun 2020 11:30:55 -0400
Subject: [PATCH] added bulk operations into StreamInterface

---
 .../telecominfraproject/wlan/stream/StreamInterface.java | 9 +++++++++
 1 file changed, 9 insertions(+)

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));
+    	}
+    }
+
 }