@@ -49,7 +49,7 @@ def __init__(
4949 self .chunk_size : int = chunk_size or 1024
5050 self .max_chunks : int = max_chunks or 20
5151
52- self ._current_index = 0
52+ self ._current_chunk_index = 0
5353 self ._total_chunks = self .get_required_chunks ()
5454 self ._initial_transaction_id : TransactionId | None = None
5555 self ._transaction_ids : list [TransactionId ] = []
@@ -192,7 +192,7 @@ def _build_proto_body(self) -> consensus_submit_message_pb2.ConsensusSubmitMessa
192192
193193 content = self .message .encode ("utf-8" )
194194
195- start_index = self ._current_index * self .chunk_size
195+ start_index = self ._current_chunk_index * self .chunk_size
196196 end_index = min (start_index + self .chunk_size , len (content ))
197197 chunk_content = content [start_index :end_index ]
198198
@@ -206,7 +206,7 @@ def _build_proto_body(self) -> consensus_submit_message_pb2.ConsensusSubmitMessa
206206 consensus_submit_message_pb2 .ConsensusMessageChunkInfo (
207207 initialTransactionID = self ._initial_transaction_id ._to_proto (),
208208 total = self ._total_chunks ,
209- number = self ._current_index + 1 ,
209+ number = self ._current_chunk_index + 1 ,
210210 )
211211 )
212212
@@ -371,7 +371,7 @@ def execute_all(
371371 responses = []
372372
373373 for chunk_index in range (self .get_required_chunks ()):
374- self ._current_index = chunk_index
374+ self ._current_chunk_index = chunk_index
375375
376376 if self ._transaction_ids and chunk_index < len (self ._transaction_ids ):
377377 self .transaction_id = self ._transaction_ids [chunk_index ]
0 commit comments