Package com.google.cloud.pubsublite.internal

Class BufferingPullSubscriber

java.lang.Object

com.google.cloud.pubsublite.internal.BufferingPullSubscriber

All Implemented Interfaces:

PullSubscriber<SequencedMessage>, AutoCloseable

public class BufferingPullSubscriber
extends Object
implements PullSubscriber<SequencedMessage>

Constructor Summary

Constructors

Constructor	Description
BufferingPullSubscriber(SubscriberFactory factory, FlowControlSettings settings)

Method Summary

Modifier and Type	Method	Description
void	close()
Optional<Offset>	nextOffset()
List<SequencedMessage>	pull()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BufferingPullSubscriber

public BufferingPullSubscriber(SubscriberFactory factory,
                               FlowControlSettings settings)
                        throws CheckedApiException

Throws:

CheckedApiException

Method Detail

pull

public List<SequencedMessage> pull()
                            throws CheckedApiException

Specified by:

pull in interface PullSubscriber<SequencedMessage>

Throws:

CheckedApiException

nextOffset

public Optional<Offset> nextOffset()

Specified by:

nextOffset in interface PullSubscriber<SequencedMessage>

close

public void close()

Specified by:

close in interface AutoCloseable