// return true if this sequence number is readable
return true if this sequence number is readable
return true if this sequence number is readable
pub fn readable(&self, sequence_number: SequenceNumber) -> bool {
        match (&self.max_buffered, &self.max_persisted) {
            (Some(max_buffered), Some(max_persisted)) => {
                &sequence_number <= max_buffered || &sequence_number <= max_persisted
            }
            (None, Some(max_persisted)) => &sequence_number <= max_persisted,
            (Some(max_buffered), _) => &sequence_number <= max_buffered,
            (None, None) => {
                false // data not yet ingested
            }
        }
    }
pub fn readable ( & self , sequence_number : SequenceNumber ) -> bool { match ( & self . max_buffered , & self . max_persisted ) { ( Some ( max_buffered ) , Some ( max_persisted ) ) => { & sequence_number <= max_buffered || & sequence_number <= max_persisted } ( None , Some ( max_persisted ) ) => & sequence_number <= max_persisted , ( Some ( max_buffered ) , _ ) => & sequence_number <= max_buffered , ( None , None ) => { false // data not yet ingested } } }
return true if this sequence number is readable
return true if this sequence number is readable
&self
sequence_number
SequenceNumber