Class BufferingPullSubscriber (1.12.22)

public class BufferingPullSubscriber implements PullSubscriber<SequencedMessage>

Inheritance

java.lang.Object > BufferingPullSubscriber

Implements

com.google.cloud.pubsublite.internal.PullSubscriber<com.google.cloud.pubsublite.proto.SequencedMessage>

Constructors

BufferingPullSubscriber(SubscriberFactory factory, FlowControlSettings settings)

public BufferingPullSubscriber(SubscriberFactory factory, FlowControlSettings settings)
Parameters
NameDescription
factorySubscriberFactory
settingsFlowControlSettings

Methods

close()

public void close()

nextOffset()

public synchronized Optional<Offset> nextOffset()
Returns
TypeDescription
Optional<Offset>

pull()

public synchronized List<SequencedMessage> pull()
Returns
TypeDescription
List<SequencedMessage>
Exceptions
TypeDescription
CheckedApiException