Class BufferingPullSubscriber (1.12.22)

Version 1.12.22

• 1.14.7 (latest)
• 1.14.4
• 1.13.8
• 1.12.22
• 1.11.2
• 1.10.0
• 1.9.4
• 1.8.0
• 1.7.1
• 1.6.3
• 1.5.5
• 1.4.12

public class BufferingPullSubscriber implements PullSubscriber<SequencedMessage>

Inheritance

java.lang.Object > BufferingPullSubscriber

Implements

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

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Constructors

BufferingPullSubscriber(SubscriberFactory factory, FlowControlSettings settings)

public BufferingPullSubscriber(SubscriberFactory factory, FlowControlSettings settings)

Parameters
Name	Description
factory	SubscriberFactory
settings	FlowControlSettings

Methods

close()

public void close()

nextOffset()

public synchronized Optional<Offset> nextOffset()

Returns
Type	Description
Optional<Offset>

pull()

public synchronized List<SequencedMessage> pull()

Returns
Type	Description
List<SequencedMessage>

Exceptions
Type	Description
CheckedApiException