pub async fn send_records(&mut self, records: DefaultRecords, update_highwatermark: bool) -> Result<(),StorageError>{
        
        for batch in records.batches {
           self.send(batch).await?;
        }

        if update_highwatermark {
            self.update_high_watermark_to_end().await?;
        }

        Ok(())
    }
/// write records to this replica, update high watermark if required
write records to this replica, update high watermark if required
write records to this replica update high watermark if required
pub async fn send_records(&mut self, records: DefaultRecords, update_highwatermark: bool) -> Result<(),StorageError>{
        for batch in records.batches {
           self.send(batch).await?;
        }
        if update_highwatermark {
            self.update_high_watermark_to_end().await?;
        }
        Ok(())
    }
pub async fn send_records ( & mut self , records : DefaultRecords , update_highwatermark : bool ) -> Result < ( ) , StorageError > { for batch in records . batches { self . send ( batch ) . await ? ; } if update_highwatermark { self . update_high_watermark_to_end ( ) . await ? ; } Ok ( ( ) ) }
write records to this replica, update high watermark if required
write records to this replica update high watermark if required
&mut self
records
DefaultRecords
update_highwatermark
bool
&mut self
records
DefaultRecords
update_highwatermark
bool