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
-
-