chore: declare public api

Author: ovr

rust/cubestore/cubestore/src/metastore/rocks_store.rs

@@ -843,6 +843,13 @@ impl RocksStoreRWLoop {
         }
     }
 
+    pub async fn send<F>(&self, fun: F) -> Result<(), CubeError>
+    where
+        F: FnOnce() -> Result<(), CubeError> + Send + 'static,
+    {
+        self.tx.send(fun).await.into()
+    }
+
     pub fn get_name(&self) -> &'static str {
         self.name
     }
@@ -1034,7 +1041,6 @@ impl RocksStore {
         let (tx, rx) = oneshot::channel::<Result<(R, Vec<MetaStoreEvent>), CubeError>>();
 
         let res = rw_loop
-            .tx
             .send(Box::new(move || {
                 let db_span = warn_long(&span_name, Duration::from_millis(100));
 
@@ -1367,7 +1373,7 @@ impl RocksStore {
         let store_name = self.details.get_name();
         let span_name = format!("{}({}) read operation: {}", store_name, loop_name, op_name);
 
-        let res = rw_loop.tx.send(Box::new(move || {
+        let res = rw_loop.send(Box::new(move || {
             let db_span = warn_long(&span_name, Duration::from_millis(100));
 
             let snapshot = db_to_send.snapshot();