Uses of Class
com.google.cloud.pubsublite.proto.SequencedMessage

Packages that use SequencedMessage

Package	Description
com.google.cloud.pubsublite
com.google.cloud.pubsublite.cloudpubsub.internal
com.google.cloud.pubsublite.internal
com.google.cloud.pubsublite.internal.wire
com.google.cloud.pubsublite.proto

Uses of SequencedMessage in com.google.cloud.pubsublite

Methods in com.google.cloud.pubsublite that return SequencedMessage

Modifier and Type	Method	Description
SequencedMessage	SequencedMessage.toProto()	Convert to a SequencedMessage proto.

Methods in com.google.cloud.pubsublite with parameters of type SequencedMessage

Modifier and Type	Method	Description
static SequencedMessage	SequencedMessage.fromProto(SequencedMessage proto)	Convert a SequencedMessage proto to a SequencedMessage.

Uses of SequencedMessage in com.google.cloud.pubsublite.cloudpubsub.internal

Method parameters in com.google.cloud.pubsublite.cloudpubsub.internal with type arguments of type SequencedMessage

Modifier and Type	Method	Description
Subscriber	ResettableSubscriberFactory.newSubscriber(Consumer<List<SequencedMessage>> messageConsumer, SubscriberResetHandler resetHandler)

Uses of SequencedMessage in com.google.cloud.pubsublite.internal

Methods in com.google.cloud.pubsublite.internal that return types with arguments of type SequencedMessage

Modifier and Type	Method	Description
Optional<SequencedMessage>	BlockingPullSubscriber.messageIfAvailable()	Pull messages if there is any ready to deliver.
Optional<SequencedMessage>	BlockingPullSubscriberImpl.messageIfAvailable()
List<SequencedMessage>	BufferingPullSubscriber.pull()

Uses of SequencedMessage in com.google.cloud.pubsublite.internal.wire

Method parameters in com.google.cloud.pubsublite.internal.wire with type arguments of type SequencedMessage

Modifier and Type	Method	Description
static boolean	Predicates.isOrdered(Iterable<SequencedMessage> messages)
Subscriber	SubscriberFactory.newSubscriber(Consumer<List<SequencedMessage>> messageConsumer)
void	SubscriberImpl.onClientResponse(List<SequencedMessage> messages)
abstract SubscriberBuilder.Builder	SubscriberBuilder.Builder.setMessageConsumer(Consumer<List<SequencedMessage>> messageConsumer)

Constructor parameters in com.google.cloud.pubsublite.internal.wire with type arguments of type SequencedMessage

Constructor	Description
SubscriberImpl(StreamFactories.SubscribeStreamFactory streamFactory, InitialSubscribeRequest baseInitialRequest, SeekRequest initialLocation, Consumer<List<SequencedMessage>> messageConsumer, SubscriberResetHandler resetHandler, boolean retryStreamRaces)

Uses of SequencedMessage in com.google.cloud.pubsublite.proto

Methods in com.google.cloud.pubsublite.proto that return SequencedMessage

Modifier and Type	Method	Description
SequencedMessage	SequencedMessage.Builder.build()
SequencedMessage	SequencedMessage.Builder.buildPartial()
static SequencedMessage	SequencedMessage.getDefaultInstance()
SequencedMessage	SequencedMessage.Builder.getDefaultInstanceForType()
SequencedMessage	SequencedMessage.getDefaultInstanceForType()
SequencedMessage	MessageResponse.Builder.getMessages(int index)	Messages from the topic partition.
SequencedMessage	MessageResponse.getMessages(int index)	Messages from the topic partition.
SequencedMessage	MessageResponseOrBuilder.getMessages(int index)	Messages from the topic partition.
static SequencedMessage	SequencedMessage.parseDelimitedFrom(InputStream input)
static SequencedMessage	SequencedMessage.parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SequencedMessage	SequencedMessage.parseFrom(byte[] data)
static SequencedMessage	SequencedMessage.parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SequencedMessage	SequencedMessage.parseFrom(com.google.protobuf.ByteString data)
static SequencedMessage	SequencedMessage.parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SequencedMessage	SequencedMessage.parseFrom(com.google.protobuf.CodedInputStream input)
static SequencedMessage	SequencedMessage.parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SequencedMessage	SequencedMessage.parseFrom(InputStream input)
static SequencedMessage	SequencedMessage.parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SequencedMessage	SequencedMessage.parseFrom(ByteBuffer data)
static SequencedMessage	SequencedMessage.parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)

Methods in com.google.cloud.pubsublite.proto that return types with arguments of type SequencedMessage

Modifier and Type	Method	Description
List<SequencedMessage>	MessageResponse.Builder.getMessagesList()	Messages from the topic partition.
List<SequencedMessage>	MessageResponse.getMessagesList()	Messages from the topic partition.
List<SequencedMessage>	MessageResponseOrBuilder.getMessagesList()	Messages from the topic partition.
com.google.protobuf.Parser<SequencedMessage>	SequencedMessage.getParserForType()
static com.google.protobuf.Parser<SequencedMessage>	SequencedMessage.parser()

Methods in com.google.cloud.pubsublite.proto with parameters of type SequencedMessage

Modifier and Type	Method	Description
MessageResponse.Builder	MessageResponse.Builder.addMessages(int index, SequencedMessage value)	Messages from the topic partition.
MessageResponse.Builder	MessageResponse.Builder.addMessages(SequencedMessage value)	Messages from the topic partition.
SequencedMessage.Builder	SequencedMessage.Builder.mergeFrom(SequencedMessage other)
static SequencedMessage.Builder	SequencedMessage.newBuilder(SequencedMessage prototype)
MessageResponse.Builder	MessageResponse.Builder.setMessages(int index, SequencedMessage value)	Messages from the topic partition.

Method parameters in com.google.cloud.pubsublite.proto with type arguments of type SequencedMessage

Modifier and Type	Method	Description
MessageResponse.Builder	MessageResponse.Builder.addAllMessages(Iterable<? extends SequencedMessage> values)	Messages from the topic partition.