1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81
use std::marker::PhantomData; use num_traits::{Float, FromPrimitive}; use specs::{System, Write}; use timelib; use type_name; use super::Time; pub struct TimeSystem<T>(PhantomData<T>); impl<T> Default for TimeSystem<T> { #[inline(always)] fn default() -> Self { TimeSystem(PhantomData) } } impl<T> TimeSystem<T> { #[inline(always)] pub fn new() -> Self { TimeSystem(PhantomData) } } impl<T> TimeSystem<T> { #[inline(always)] pub fn name() -> &'static str { type_name::get::<Self>() } } impl<'a, T> System<'a> for TimeSystem<T> where T: 'static + Send + Sync + Float + FromPrimitive, { type SystemData = Write<'a, Time<T>>; #[inline] fn run(&mut self, mut time: Self::SystemData) { time.update(T::from_f64(timelib::precise_time_s()).unwrap()); } } #[cfg(test)] mod test { use super::super::TimeBundle; use super::*; use std::{thread, time}; use specs::{DispatcherBuilder, World}; use specs_bundler::SpecsBundler; #[test] fn test_system() { let mut world = World::new(); let mut dispatcher = SpecsBundler::new(&mut world, DispatcherBuilder::new()) .bundle(TimeBundle::<f32>::new()) .unwrap() .build(); for _ in 0..60 { dispatcher.dispatch(&mut world.res); thread::sleep(time::Duration::from_millis(16)); } assert_eq!(world.read_resource::<Time<f32>>().frame(), 60); } #[test] fn test_time_system_name() { assert_eq!(TimeSystem::<f32>::name(), "time_system::TimeSystem<f32>"); struct Example; assert_eq!( TimeSystem::<Example>::name(), "time_system::TimeSystem<time_system::test::test_time_system_name::Example>" ); } }