see https://github.com/apache/pulsar-client-reactive/pull/29/files#r1033304281
It would be useful to refer to ReactiveMessageReaderBuilder#endOfStreamAction in the documentation for these methods. When endOfStreamAction == EndOfStreamAction#COMPLETE, readOne will return an empty Mono if the reader reaches the end of the stream of messages.
see https://github.com/apache/pulsar-client-reactive/pull/29/files#r1033304281
It would be useful to refer to ReactiveMessageReaderBuilder#endOfStreamAction in the documentation for these methods. When endOfStreamAction == EndOfStreamAction#COMPLETE, readOne will return an empty Mono if the reader reaches the end of the stream of messages.