diff options
Diffstat (limited to 'src/transport')
| -rw-r--r-- | src/transport/traffic.rs | 10 |
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(); |
