Method copy_memtable_to_database

src/darkbird/persistent_worker.rs:105–133

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

    }

    pub async fn copy_memtable_to_database<K, Doc, THandler>(
        &self,
        storage: Arc<Storage<K, Doc>>,
        handler: &THandler,
    ) where
        THandler: Setter<K, Doc>,
        Doc: Serialize + DeserializeOwned + Clone + Send + 'static + Document,
        K: Serialize
            + DeserializeOwned
            + PartialOrd
            + Ord
            + PartialEq
            + Eq
            + Hash
            + Clone
            + Send
            + Sync
            + 'static,
    {
        for refi in storage.iter() {
            let key = refi.key();
            let document = refi.value();

            if let Err(Stop) = handler.handle_setter(&self.db_session, key, document).await {
                println!("Stop copying ....");
                return;
            }
        }
    }

    pub async fn load_memtable_from_database<K, Doc, THandler>(
        &self,