peterxcli opened a new pull request, #1481: URL: https://github.com/apache/ratis/pull/1481
## What changes were proposed in this pull request? * Added a new `DataStreamInput` interface and its implementation `DataStreamInputImpl` for asynchronous, zero-copy read-only data streaming, including the `readAsync()` method for consuming replies and proper resource release on close. * Extended the `DataStreamApi` interface and its implementation to provide `streamReadOnly()` methods for creating read-only streams. * Introduced the new `DataStreamReplyByteBuf` class to support replies backed by Netty `ByteBuf`. * Added a new overload of `streamAsync()` in the `DataStreamClientRpc` interface that takes a reply consumer, supporting multiple replies per request. ## What is the link to the Apache JIRA https://issues.apache.org/jira/browse/RATIS-2546 ## How was this patch tested? (Please explain how this patch was tested. Ex: unit tests, manual tests) (If this patch involves UI changes, please attach a screen-shot; otherwise, remove this) -- 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]
