chore(define-async-host-func): update to wasmedge-sdk v0.14.0

Signed-off-by: csh <458761603@qq.com>

Cargo.toml

@@ -9,6 +9,7 @@ members = [
     "call-wasm-lib-from-host/wasm-lib",
     "call-wasm-lib-with-external-deps/host-app",
     "call-wasm-lib-with-external-deps/wasm-lib",
+    "define-async-host-func",
 ]
 
 

define-async-host-func/Cargo.toml

@@ -4,5 +4,5 @@ name = "define-async-host-func"
 version = "0.4.0"
 
 [dependencies]
-tokio = { version = "1.28", features = ["full"] }
-wasmedge-sdk = { version = "0.13.0", features = ["async"] }
+wasmedge-sdk.workspace = true
+tokio.workspace = true

define-async-host-func/README.md

@@ -24,15 +24,17 @@ Now let's build and run this example.
   # NOTICE that the installation script needs `sudo` access
 
   # install wasmedge to the directory /usr/local/
-  curl -sSf https://raw.githubusercontent.com/WasmEdge/WasmEdge/master/utils/install.sh | bash -s -- -v 0.13.5 -p /usr/local
+  curl -sSf https://raw.githubusercontent.com/WasmEdge/WasmEdge/master/utils/install.sh | bash -s -- -v 0.14.0
+  source $HOME/.wasmedge/env
   ```
 
   > For users in China mainland (中国大陆地区), try the following command to install WasmEdge Runtime if failed to run the command above
   >
   > ```bash
   > # NOTICE that the installation script needs `sudo` access
   >
-  > bash install_zh.sh -v 0.13.5 -p /usr/local
+  > bash install_zh.sh -v 0.14.0
+  > source $HOME/.wasmedge/env
   > ```
 
 - Download example

define-async-host-func/src/main.rs

@@ -1,38 +1,41 @@
+use std::{collections::HashMap, future::Future};
+
 use wasmedge_sdk::{
-    async_host_function, error::HostFuncError, params, wasi::r#async::AsyncState, Caller,
-    ImportObjectBuilder, NeverType, VmBuilder, WasmValue,
+    error::CoreError,
+    r#async::{import::ImportObjectBuilder, vm::Vm, AsyncInstance},
+    CallingFrame, Store, WasmValue,
 };
 
-#[async_host_function]
-async fn async_hello(
-    _frame: CallingFrame,
+fn async_hello(
+    _data: &mut (),
+    _inst: &mut AsyncInstance,
+    _frame: &mut CallingFrame,
     _inputs: Vec<WasmValue>,
-) -> Result<Vec<WasmValue>, HostFuncError> {
-    for _ in 0..10 {
-        println!("[async hello] say hello");
-        tokio::time::sleep(std::time::Duration::from_secs(1)).await;
-    }
+) -> Box<dyn Future<Output = Result<Vec<WasmValue>, CoreError>> + Send> {
+    Box::new(async {
+        for _ in 0..10 {
+            println!("[async hello] say hello");
+            tokio::time::sleep(std::time::Duration::from_secs(1)).await;
+        }
 
-    println!("[async hello] Done!");
+        println!("[async hello] Done!");
 
-    Ok(vec![])
+        Ok(vec![])
+    })
 }
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
     // create an import module
-    let import = ImportObjectBuilder::new()
-        .with_async_func::<(), (), NeverType>("hello", async_hello, None)?
-        .build::<NeverType>("extern", None)?;
+    let mut builder = ImportObjectBuilder::new("extern", ()).unwrap();
+    builder.with_func::<(), ()>("hello", async_hello).unwrap();
+    let mut import = builder.build();
 
+    let mut instances = HashMap::new();
+    instances.insert("extern".into(), &mut import);
+    let store = Store::new(None, instances).unwrap();
     // create a Vm
-    let mut vm = VmBuilder::new().build()?;
-
-    // register the import module
-    vm.register_import_module(&import)?;
-
-    // create an async state
-    let async_state = AsyncState::new();
+    let mut vm = Vm::new(store);
 
     async fn tick() {
         let mut i = 0;
@@ -45,9 +48,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     tokio::spawn(tick());
 
     // run the async host function
-    let _ = vm
-        .run_func_async(&async_state, Some("extern"), "hello", params!())
-        .await?;
+    let _ = vm.run_func(Some("extern"), "hello", []).await?;
 
     Ok(())
 }