/// update the clients that we have offset changed
update the clients that we have offset changed
update the clients that we have offset changed
async fn update_offset_to_clients(&self) {
        if let Some(leader_replica) = self.leaders_state.get_replica(&self.id) {
            let event = OffsetUpdateEvent {
                hw: leader_replica.hw(),
                leo: leader_replica.leo(),
                replica_id: self.id.clone()
            };
            self.offset_sender.send(event).await;
        } else {
            warn!("no replica is found: {} for offset update", self.id);
        }
    }
async fn update_offset_to_clients ( & self ) { if let Some ( leader_replica ) = self . leaders_state . get_replica ( & self . id ) { let event = OffsetUpdateEvent { hw : leader_replica . hw ( ) , leo : leader_replica . leo ( ) , replica_id : self . id . clone ( ) } ; self . offset_sender . send ( event ) . await ; } else { warn ! ( " " self id ) ; } }
update the clients that we have offset changed
update the clients that we have offset changed
&self