Method load_memtable_from_database

src/darkbird/persistent_worker.rs:135–166

(
        &self,
        storage: Arc<Storage<K, Doc>>,
        handler: &THandler,
    )

    }

    pub async fn load_memtable_from_database<K, Doc, THandler>(
        &self,
        storage: Arc<Storage<K, Doc>>,
        handler: &THandler,
    ) -> Result<(), SessionResult>
    where
        THandler: Getter<K, Doc>,
        Doc: Serialize + DeserializeOwned + Clone + Send + 'static + Document,
        K: Serialize
            + DeserializeOwned
            + PartialOrd
            + Ord
            + PartialEq
            + Eq
            + Hash
            + Clone
            + Send
            + Sync
            + 'static,
    {
        // Call Getter
        let list = handler.handle_getter(&self.db_session).await;

        // Fill Memtable
        for (key, document) in list.into_iter() {
            if let Err(e) = storage.insert(key, document).await {
                return Err(e);
            }
        }

        return Ok(());
    }
}