| @@ -31,6 +31,7 @@ version = "0.1.0" | |||||
| dependencies = [ | dependencies = [ | ||||
| "asparit", | "asparit", | ||||
| "async-ecs-derive", | "async-ecs-derive", | ||||
| "crossbeam-queue", | |||||
| "futures", | "futures", | ||||
| "hashbrown", | "hashbrown", | ||||
| "hibitset", | "hibitset", | ||||
| @@ -146,6 +147,16 @@ dependencies = [ | |||||
| "scopeguard", | "scopeguard", | ||||
| ] | ] | ||||
| [[package]] | |||||
| name = "crossbeam-queue" | |||||
| version = "0.3.0" | |||||
| source = "registry+https://github.com/rust-lang/crates.io-index" | |||||
| checksum = "6b2a58563f049aa3bae172bc4120f093b5901161c629f280a1f40ba55317d774" | |||||
| dependencies = [ | |||||
| "cfg-if 1.0.0", | |||||
| "crossbeam-utils", | |||||
| ] | |||||
| [[package]] | [[package]] | ||||
| name = "crossbeam-utils" | name = "crossbeam-utils" | ||||
| version = "0.8.0" | version = "0.8.0" | ||||
| @@ -1 +1 @@ | |||||
| Subproject commit 27fd692518d3d77a2dc7c82d0ba5b222305d305d | |||||
| Subproject commit e3d7c56297232aa66e720cc0766b1c25bc11420d | |||||
| @@ -1 +1 @@ | |||||
| Subproject commit 39fa7475beefd197f2d99e8b30ae4ec8c4e5ba12 | |||||
| Subproject commit 4a29fa124c3dfde75949d606d014de1cd554e923 | |||||
| @@ -1 +1 @@ | |||||
| Subproject commit 14f0bdde2d5e4154a9f895e3b0a42970bd2aca5e | |||||
| Subproject commit 7a33669aa8f000d15e56209dcf93f81112f08a24 | |||||
| @@ -4,7 +4,8 @@ use std::time::{Duration, Instant}; | |||||
| use async_ecs::{ | use async_ecs::{ | ||||
| asparit::{Driver, ParallelIterator}, | asparit::{Driver, ParallelIterator}, | ||||
| dispatcher::Error as DispatcherError, | dispatcher::Error as DispatcherError, | ||||
| AsyncSystem, Dispatcher, Join, ParJoin, ReadStorage, System, VecStorage, World, WriteStorage, | |||||
| AsyncSystem, Builder as EntityBuilder, Dispatcher, Join, ParJoin, ReadStorage, System, | |||||
| VecStorage, World, WriteStorage, | |||||
| }; | }; | ||||
| use async_ecs_derive::Component; | use async_ecs_derive::Component; | ||||
| use futures::future::{BoxFuture, FutureExt}; | use futures::future::{BoxFuture, FutureExt}; | ||||
| @@ -61,6 +62,7 @@ async fn run() -> Result<(), Error> { | |||||
| let start = Instant::now(); | let start = Instant::now(); | ||||
| dispatcher.dispatch(&world).await?; | dispatcher.dispatch(&world).await?; | ||||
| world.maintain().await; | |||||
| let end = Instant::now(); | let end = Instant::now(); | ||||