apache / apache/pulsar-client-reactive
Document endOfStreamAction and reference it in ReactiveMessageReader javadoc
Open
- Dominant language
- Java
- Stars
- 67
- Forks
- 23
- Avg merge
- 22h
- Merged PRs (30d)
- 2
Description
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.
Contributor guide
Assessment
This issue has not been assessed yet.