feat: sync version of submit

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "gradio"
-version = "0.2.4"
+version = "0.2.5"
 edition = "2021"
 authors = ["Jacob Lin <[email protected]>"]
 description = "Gradio Client in Rust."

src/stream.rs

@@ -59,6 +59,9 @@ impl PredictionStream {
 
     pub async fn next(&mut self) -> Option<Result<QueueDataMessage>> {
         let event = self.es.next().await;
+        if event.is_none() {
+            return Some(Err(Error::msg("Stream ended")));
+        }
         let event = event.unwrap();
 
         match event {

src/sync.rs

@@ -1,6 +1,8 @@
 use crate::client::{Client, ClientOptions};
 use crate::data::{GradioFileData, PredictionInput, PredictionOutput};
-use anyhow::Result;
+use crate::stream::PredictionStream;
+use crate::structs::QueueDataMessage;
+use anyhow::{Error, Result};
 use std::path::Path;
 use tokio::runtime::Runtime;
 
@@ -11,6 +13,16 @@ impl Client {
         Ok(client)
     }
 
+    pub fn submit_sync(
+        &self,
+        path: &str,
+        inputs: Vec<PredictionInput>,
+    ) -> Result<PredictionStream> {
+        let rt = Runtime::new()?;
+        let output = rt.block_on(self.submit(path, inputs))?;
+        Ok(output)
+    }
+
     pub fn predict_sync(
         &self,
         path: &str,
@@ -39,3 +51,15 @@ impl GradioFileData {
         Ok(())
     }
 }
+
+impl PredictionStream {
+    pub fn next_sync(&mut self) -> Option<Result<QueueDataMessage>> {
+        let rt = Runtime::new();
+        if rt.is_err() {
+            return Some(Err(Error::msg("Runtime error")));
+        }
+        let rt = rt.unwrap();
+        let output = rt.block_on(self.next())?;
+        Some(output)
+    }
+}