Crates.io | bevy_async_task |
lib.rs | bevy_async_task |
version | |
source | src |
created_at | 2024-03-24 01:27:26.510753 |
updated_at | 2024-12-02 17:03:56.122573 |
description | Ergonomic abstractions to async programming in Bevy |
homepage | |
repository | https://github.com/loopystudios/bevy_async_task |
max_upload_size | |
id | 1184013 |
Cargo.toml error: | TOML parse error at line 18, column 1 | 18 | autolib = false | ^^^^^^^ unknown field `autolib`, expected one of `name`, `version`, `edition`, `authors`, `description`, `readme`, `license`, `repository`, `homepage`, `documentation`, `build`, `resolver`, `links`, `default-run`, `default_dash_run`, `rust-version`, `rust_dash_version`, `rust_version`, `license-file`, `license_dash_file`, `license_file`, `licenseFile`, `license_capital_file`, `forced-target`, `forced_dash_target`, `autobins`, `autotests`, `autoexamples`, `autobenches`, `publish`, `metadata`, `keywords`, `categories`, `exclude`, `include` |
size | 0 |
A minimum crate for ergonomic abstractions to async programming in Bevy. There is full API support for wasm and native. Android and iOS are untested (Help needed).
Bevy Async Task provides Bevy system parameters to run asynchronous tasks in the background on web and native with timeouts and output capture.
bevy | bevy_async_task |
---|---|
0.15 | 0.3-0.4, main |
0.14 | 0.2 |
0.13 | 0.1 |
<= 0.13 | Unsupported |
There are several examples for reference.
You can also run examples on web:
# Make sure the Rust toolchain supports the wasm32 target
rustup target add wasm32-unknown-unknown
cargo run_wasm --example simple
Poll one task at a time with AsyncTaskRunner<T>
:
async fn long_task() -> u32 {
sleep(Duration::from_millis(1000)).await;
5
}
fn my_system(mut task_runner: AsyncTaskRunner<u32>) {
if task_runner.is_idle() {
task_executor.start(long_task());
info!("Started!");
}
match task_runner.poll() {
Poll::Ready(v) => {
info!("Received {v:?}");
}
Poll::Pending => {
// Waiting...
}
}
}
Poll many similar tasks simultaneously with AsyncTaskPool<T>
:
fn my_system(mut task_pool: AsyncTaskPool<u64>) {
if task_pool.is_idle() {
info!("Queueing 5 tasks...");
for i in 1..=5 {
task_pool.spawn(async move { // Closures work too!
sleep(Duration::from_millis(i * 1000)).await;
i
});
}
}
for status in task_pool.iter_poll() {
if let Poll::Ready(v) = status {
info!("Received {v:?}");
}
}
}
We also have a cross_system
example.
All Loopy projects and development happens in the Loopy Discord. The discord is open to the public.
Contributions are welcome by pull request. The Rust code of conduct applies.
Licensed under either of
at your option
Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.