Uses of Interface
org.apache.pulsar.client.api.Reader

Packages that use Reader

Package	Description
org.apache.pulsar.client.api	Pulsar Client API.

Uses of Reader in org.apache.pulsar.client.api

Methods in org.apache.pulsar.client.api that return Reader

Modifier and Type	Method	Description
Reader<T>	ReaderBuilder.create()	Finalize the creation of the Reader instance.

Methods in org.apache.pulsar.client.api that return types with arguments of type Reader

Modifier and Type	Method	Description
CompletableFuture<Reader<T>>	ReaderBuilder.createAsync()	Finalize the creation of the Reader instance in asynchronous mode.

Methods in org.apache.pulsar.client.api with parameters of type Reader

Modifier and Type	Method	Description
Message<T>	ReaderInterceptor.beforeRead(Reader<T> reader, Message<T> message)	This is called just before the message is returned by readNext(), ReaderListener.received(Reader, Message) or the CompletableFuture returned by readNextAsync() completes.
default void	ReaderListener.reachedEndOfTopic(Reader<T> reader)	Get the notification when a topic is terminated.
void	ReaderListener.received(Reader<T> reader, Message<T> msg)	This method is called whenever a new message is received.