Merge pull request #233 from alexcrichton/accessor-apis

Add `&Accessor<T, D>` to all future/stream APIs

Author: alexcrichton

crates/misc/component-async-tests/Cargo.toml

@@ -12,7 +12,7 @@ workspace = true
 
 [dependencies]
 anyhow = { workspace = true }
-futures = { workspace = true }
+futures = { workspace = true, features = ['async-await'] }
 env_logger = { workspace = true }
 tempfile = { workspace = true }
 tokio = { workspace = true, features = [

crates/misc/component-async-tests/src/resource_stream.rs

@@ -51,13 +51,9 @@ impl bindings::local::local::resource_stream::HostConcurrent for Ctx {
             async fn run(self, accessor: &Accessor<T, Ctx>) -> Result<()> {
                 let mut tx = Some(self.tx);
                 for _ in 0..self.count {
-                    tx = accessor
-                        .with(|mut view| {
-                            let item = view.get().table().push(ResourceStreamX)?;
-                            Ok::<_, anyhow::Error>(tx.take().unwrap().write_all(Some(item)))
-                        })?
-                        .await
-                        .0;
+                    let item =
+                        accessor.with(|mut view| view.get().table().push(ResourceStreamX))?;
+                    tx = tx.take().unwrap().write_all(accessor, Some(item)).await.0;
                 }
                 Ok(())
             }