Skip to main content

kmp_adapter_embedded/adapter/
read_snapshot.rs

1use kmp_domain::ReadSnapshotProvider;
2
3use super::store::EmbeddedKernelStore;
4
5impl ReadSnapshotProvider<EmbeddedKernelStore, EmbeddedKernelStore> for EmbeddedKernelStore {
6    fn open_snapshot(
7        &self,
8    ) -> kmp_domain::ReadSnapshotFuture<'_, EmbeddedKernelStore, EmbeddedKernelStore> {
9        Box::pin(async {
10            let snapshot = self.read_snapshot().await?;
11            Ok((snapshot.clone(), snapshot))
12        })
13    }
14}