Method subscribe

src/darkbird/database.rs:150–171

(&self, sender: Sender<Event<K, Doc>>)

    #[inline]        
    pub async fn subscribe<K, Doc>(&self, sender: Sender<Event<K, Doc>>) -> Result<(), SessionResult> 
    where
        Doc: Serialize + DeserializeOwned + Clone + Send + 'static + Document,
        K:  Serialize
            + DeserializeOwned
            + PartialOrd
            + Ord
            + PartialEq
            + Eq
            + Hash
            + Clone
            + Send
            + Sync
            + 'static
    {
        match self.datastores.get::<Storage<K, Doc>>() {
            None => Err(SessionResult::DataStoreNotFound),
            Some(datastore) => {
                datastore.subscribe(sender).await
            }
        }
    }

    #[inline]        
    pub async fn insert<K, Doc>(&self, key: K, doc: Doc) -> Result<(), SessionResult>