Interface PullSubscriber<T>
-
- All Superinterfaces:
AutoCloseable
- All Known Implementing Classes:
BufferingPullSubscriber
public interface PullSubscriber<T> extends AutoCloseable
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Optional<Offset>nextOffset()List<T>pull()-
Methods inherited from interface java.lang.AutoCloseable
close
-
-
-
-
Method Detail
-
pull
List<T> pull() throws CheckedApiException
- Throws:
CheckedApiException
-
-