diff --git a/crates/papyrus_protobuf/src/consensus.rs b/crates/papyrus_protobuf/src/consensus.rs index 2b462e8d10..652d783042 100644 --- a/crates/papyrus_protobuf/src/consensus.rs +++ b/crates/papyrus_protobuf/src/consensus.rs @@ -48,7 +48,7 @@ impl ConsensusMessage { pub struct StreamMessage> + TryFrom, Error = ProtobufConversionError>> { pub message: T, pub stream_id: u64, - pub chunk_id: u64, + pub message_id: u64, pub fin: bool, } diff --git a/crates/papyrus_protobuf/src/converters/consensus.rs b/crates/papyrus_protobuf/src/converters/consensus.rs index f01a569b31..c3f65f773a 100644 --- a/crates/papyrus_protobuf/src/converters/consensus.rs +++ b/crates/papyrus_protobuf/src/converters/consensus.rs @@ -119,7 +119,7 @@ impl> + TryFrom, Error = ProtobufConversionError>> Ok(Self { message: T::try_from(value.message)?, stream_id: value.stream_id, - chunk_id: value.chunk_id, + message_id: value.message_id, fin: value.fin, }) } @@ -132,7 +132,7 @@ impl> + TryFrom, Error = ProtobufConversionError>> From< Self { message: value.message.into(), stream_id: value.stream_id, - chunk_id: value.chunk_id, + message_id: value.message_id, fin: value.fin, } }