fn observe(&mut self, index_range: Range<StreamIndex>) {
        for index in index_range.start.get()..index_range.end.get() {
            let entry = loop {
                match self.entries.front() {
                    // Discard all timeline entries with indexes smaller than the
                    // observed index.
                    Some(entry) if entry.index <= index.into() => {
                        self.entries.pop_front().unwrap();
                        continue;
                    }
                    Some(entry) => break entry,
                    _ => return,
                }
            };

            self.histogram.observe(entry.time.elapsed());
        }
    }
/// Records one histogram observation for every message in the given index
/// range, with the time elapsed since the matching `MessageTime` entry (the
/// first one with `index >= message.index`).
Records one histogram observation for every message in the given index
range, with the time elapsed since the matching `MessageTime` entry (the
first one with `index >= message.index`).
Records one histogram observation for every message in the given index range with the time elapsed since the matching ` MessageTime ` entry ( the first one with ` index > = message . index ` ) .
fn observe(&mut self, index_range: Range<StreamIndex>) {
        for index in index_range.start.get()..index_range.end.get() {
            let entry = loop {
                match self.entries.front() {
                    // Discard all timeline entries with indexes smaller than the
                    // observed index.
                    Some(entry) if entry.index <= index.into() => {
                        self.entries.pop_front().unwrap();
                        continue;
                    }
                    Some(entry) => break entry,
                    _ => return,
                }
            };
            self.histogram.observe(entry.time.elapsed());
        }
    }
fn observe ( & mut self , index_range : Range < StreamIndex > ) { for index in index_range . start . get ( ) .. index_range . end . get ( ) { let entry = loop { match self . entries . front ( ) { // Discard all timeline entries with indexes smaller than the // observed index. Some ( entry ) if entry . index <= index . into ( ) => { self . entries . pop_front ( ) . unwrap ( ) ; continue ; } Some ( entry ) => break entry , _ => return , } } ; self . histogram . observe ( entry . time . elapsed ( ) ) ; } }
Records one histogram observation for every message in the given index
range, with the time elapsed since the matching `MessageTime` entry (the
first one with `index >= message.index`).
Records one histogram observation for every message in the given index range with the time elapsed since the matching ` MessageTime ` entry ( the first one with ` index > = message . index ` ) .
&mut self
index_range
Range<StreamIndex>
&mut self
index_range
Range<StreamIndex>