feat: add sync_once function

Author: jianggang

src/feature_probe.rs

@@ -6,11 +6,9 @@ use std::collections::HashMap;
 use std::fmt::Debug;
 use std::sync::Arc;
 use tracing::trace;
-
-use crate::{
-    config::Config,
-    evaluate::{EvalDetail, Repository},
-};
+#[cfg(all(feature = "use_tokio", feature = "realtime"))]
+use crate::sync::SyncType;
+use crate::{config::Config, evaluate::{EvalDetail, Repository}};
 use crate::{sync::Synchronizer, FPConfig};
 use crate::{sync::UpdateCallback, user::FPUser};
 use crate::{FPDetail, SdkAuthorization, Toggle};
@@ -248,6 +246,18 @@ impl FeatureProbe {
         syncer.start_sync(self.config.start_wait, self.should_stop.clone());
     }
 
+    #[cfg(all(feature = "use_tokio", feature = "realtime"))]
+    pub fn sync_once(&self , t: SyncType) {
+        trace!("sync now url {}", &self.config.toggles_url);
+        let syncer = match &self.syncer {
+            Some(syncer) => syncer.clone(),
+            None => return,
+        };
+        tokio::spawn(async move {
+            syncer.sync_now(t).await.expect("sync once error");
+        });
+    }
+
     #[cfg(all(feature = "use_tokio", feature = "realtime"))]
     fn connect_socket(&mut self) {
         let mut slf = self.clone();
@@ -297,7 +307,6 @@ impl FeatureProbe {
 
     #[cfg(all(feature = "use_tokio", feature = "realtime"))]
     fn socket_on_update(slf: Self, payload: Option<socketio_rs::Payload>) -> SocketCallback {
-        use crate::sync::SyncType;
 
         trace!("socket_on_update: {:?}", payload);
         async move {