Remove unnecessary Subscriber type parameter

This commit is contained in:
Warren Zhu 2018-05-25 10:41:50 +08:00
Родитель 79aa72d19b
Коммит c1eb444ff2
1 изменённых файлов: 2 добавлений и 3 удалений

Просмотреть файл

@ -13,16 +13,15 @@ import java.util.function.Consumer;
* {@link Checkpointer} callback to checkpoint the messages successfully processed
*
* @param <T> message type parameter
* @param <I> {@link Iterable} of message type parameter
*
* @author Warren Zhu
*/
public interface Subscriber<T, I extends Iterable<T>> {
public interface Subscriber<T> {
/**
* Start receiving message, then process using provided {@link Consumer}
*/
void subscribe(Consumer<I> consumer);
void subscribe(Consumer<Iterable<T>> consumer);
/**
* Stop receiving message