Fix compile

Author: alexcrichton

crates/wasi-http/tests/all/p3/incoming.rs

@@ -40,7 +40,7 @@ pub async fn run_wasi_http<E: Into<ErrorCode> + 'static>(
     let instance = linker.instantiate_async(&mut store, &component).await?;
     let proxy = Proxy::new(&mut store, &instance)?;
     let res = match instance
-        .run_with(&mut store, async |s| proxy.handle(s, req).await)
+        .run_concurrent(&mut store, async |s| proxy.handle(s, req).await)
         .await??
     {
         Ok(res) => res,
@@ -49,7 +49,7 @@ pub async fn run_wasi_http<E: Into<ErrorCode> + 'static>(
     let (res, io) = Response::resource_into_http(&mut store, res)?;
     let (parts, body) = res.into_parts();
     let (res, body) = try_join!(
-        instance.run_with(&mut store, async |store| io
+        instance.run_concurrent(&mut store, async |store| io
             .run(store, async { Ok(()) })
             .await),
         async { Ok(body.collect().await) },

crates/wasi-http/tests/all/p3/outgoing.rs

@@ -35,7 +35,7 @@ async fn run(path: &str, server: &Server) -> anyhow::Result<()> {
     let instance = linker.instantiate_async(&mut store, &component).await?;
     let command = Command::new(&mut store, &instance)?;
     instance
-        .run_with(store, async |store| {
+        .run_concurrent(store, async |store| {
             command.wasi_cli_run().call_run(store).await
         })
         .await

src/commands/run.rs

@@ -506,7 +506,7 @@ impl RunCommand {
                         wasmtime_wasi::p3::bindings::Command::new(&mut *store, &instance)
                     {
                         instance
-                            .run_with(&mut *store, async |store| {
+                            .run_concurrent(&mut *store, async |store| {
                                 command.wasi_cli_run().call_run(store).await
                             })
                             .await?

src/commands/serve.rs

@@ -974,7 +974,7 @@ async fn handle_request(
             let (req, body) = req.into_parts();
             let body = body.map_err(p3::http::types::ErrorCode::from_hyper_request_error);
             let res = instance
-                .run_with(&mut store, async |store| {
+                .run_concurrent(&mut store, async |store| {
                     proxy
                         .handle(store, http::Request::from_parts(req, body))
                         .await
@@ -983,7 +983,7 @@ async fn handle_request(
             let (res, io) = wasmtime_wasi_http::p3::Response::resource_into_http(&mut store, res)?;
             tokio::task::spawn(async move {
                 instance
-                    .run_with(&mut store, async |store| {
+                    .run_concurrent(&mut store, async |store| {
                         // TODO: Report transmit errors
                         let guest_io_result = async { Ok(()) };
                         io.run(store, guest_io_result).await