aboutsummaryrefslogtreecommitdiffstats
path: root/src/transport/traffic.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport/traffic.rs')
-rw-r--r--src/transport/traffic.rs10
1 files changed, 10 insertions, 0 deletions
diff --git a/src/transport/traffic.rs b/src/transport/traffic.rs
index bac0da7..5ff588e 100644
--- a/src/transport/traffic.rs
+++ b/src/transport/traffic.rs
@@ -325,6 +325,16 @@ impl MessageLog {
}
/// The messages after `seq`, the latest `most` of them.
+ /// The message `seq` written out, while it is kept.
+ pub(crate) fn text_of(&self, seq: u64) -> Option<String> {
+ let inner = self.inner.lock_or_recover();
+ inner
+ .entries
+ .iter()
+ .find(|entry| entry.seq == seq)
+ .map(|entry| entry.text.clone())
+ }
+
pub(crate) fn after(&self, seq: u64, most: usize) -> Vec<Logged> {
let inner = self.inner.lock_or_recover();
let newer: Vec<&Logged> = inner.entries.iter().filter(|e| e.seq > seq).collect();