mirror of
https://github.com/Telecominfraproject/wlan-cloud-base-sonartest.git
synced 2025-11-01 19:17:52 +00:00
added bulk operations into StreamInterface
This commit is contained in:
@@ -1,11 +1,20 @@
|
|||||||
package com.telecominfraproject.wlan.stream;
|
package com.telecominfraproject.wlan.stream;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @author ekeddy
|
* @author ekeddy
|
||||||
|
* @author dtop
|
||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
public interface StreamInterface<T> {
|
public interface StreamInterface<T> {
|
||||||
|
|
||||||
void publish(T record);
|
void publish(T record);
|
||||||
|
|
||||||
|
default void publish(List<T> records) {
|
||||||
|
if(records!=null) {
|
||||||
|
records.forEach(r -> publish(r));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user