hangc0276 commented on code in PR #24597:
URL: https://github.com/apache/pulsar/pull/24597#discussion_r2250280015
##########
pulsar-broker/src/main/java/org/apache/pulsar/client/api/RawReader.java:
##########
@@ -101,4 +101,15 @@ static CompletableFuture<RawReader> create(PulsarClient
client,
* Close the raw reader.
*/
CompletableFuture<Void> closeAsync();
+
+ /**
+ * Stop requesting new messages from the broker until {@link #resume()} is
called. Note that this might cause
+ * {@link #readNextAsync()} to block until {@link #resume()} is called and
new messages are pushed by the broker.
+ */
+ void pause();
Review Comment:
Added.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
