pub struct DeterministicReplayer<'a> { /* private fields */ }Expand description
Replays an episode as a sorted stream of stamped records.
Implementations§
Source§impl<'a> DeterministicReplayer<'a>
impl<'a> DeterministicReplayer<'a>
Sourcepub fn new(episode: &'a MemoryEpisode) -> Self
pub fn new(episode: &'a MemoryEpisode) -> Self
Creates a replayer that walks the episode in index order.
Sourcepub fn next_record(&mut self) -> Option<&'a StampedRecord>
pub fn next_record(&mut self) -> Option<&'a StampedRecord>
Returns the next record, if any.
Sourcepub fn next_bundle(
&mut self,
primary: &TopicId,
others: &[TopicId],
window: SyncWindow,
) -> SyncResult<Option<HashMap<TopicId, &'a StampedRecord>>>
pub fn next_bundle( &mut self, primary: &TopicId, others: &[TopicId], window: SyncWindow, ) -> SyncResult<Option<HashMap<TopicId, &'a StampedRecord>>>
Bundles nearest-neighbor matches across required topics around the next primary-topic message.
Auto Trait Implementations§
impl<'a> Freeze for DeterministicReplayer<'a>
impl<'a> RefUnwindSafe for DeterministicReplayer<'a>
impl<'a> Send for DeterministicReplayer<'a>
impl<'a> Sync for DeterministicReplayer<'a>
impl<'a> Unpin for DeterministicReplayer<'a>
impl<'a> UnsafeUnpin for DeterministicReplayer<'a>
impl<'a> UnwindSafe for DeterministicReplayer<'a>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more