Class BufferingPullSubscriber (1.9.3)

Version 1.9.3

• 1.14.8 (latest)
• 1.14.7
• 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.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