caicancai commented on code in PR #1780:
URL: https://github.com/apache/iggy/pull/1780#discussion_r2083544374
##########
core/examples/src/shared/stream.rs:
##########
@@ -24,13 +24,16 @@ use iggy::prelude::IggyError;
pub struct PrintEventConsumer {}
impl MessageConsumer for PrintEventConsumer {
- async fn consume(&self, message: ReceivedMessage) -> Result<(), IggyError>
{
+ async fn consume(&self, messages: ReceivedMessage) -> Result<(),
IggyError> {
Review Comment:
One reason is that you re-declare the variable `let message =
String::from_utf8_lossy(raw_message)`; in the function, which makes it
impossible to call the original message information.
--
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]
