Method vec_subscribe

src/darkbird/database.rs:26–33

(&self, sender: Sender<Event<VectorId, Vector>>)

    #[inline]        
    pub async fn vec_subscribe(&self, sender: Sender<Event<VectorId, Vector>>) -> Result<(), SessionResult> {
        match self.datastores.get::<VecStorage>() {
            None => Err(SessionResult::DataStoreNotFound),
            Some(datastore) => {
                datastore.subscribe(sender).await
            }
        }
    }

    #[inline]        
    pub async fn vec_insert(&self, vector_id: VectorId, vector: Vec<f32>) -> Result<(), SessionResult> {