From 080cc42bb1da09059dbc35049a7ded0649961e0c Mon Sep 17 00:00:00 2001 From: HampusM Date: Mon, 29 Aug 2022 20:52:56 +0200 Subject: feat: implement async functionality --- examples/async/animals/cat.rs | 22 ++++++++++++++++ examples/async/animals/dog.rs | 22 ++++++++++++++++ examples/async/animals/human.rs | 36 ++++++++++++++++++++++++++ examples/async/animals/mod.rs | 3 +++ examples/async/bootstrap.rs | 28 ++++++++++++++++++++ examples/async/interfaces/cat.rs | 4 +++ examples/async/interfaces/dog.rs | 4 +++ examples/async/interfaces/human.rs | 4 +++ examples/async/interfaces/mod.rs | 3 +++ examples/async/main.rs | 52 ++++++++++++++++++++++++++++++++++++++ 10 files changed, 178 insertions(+) create mode 100644 examples/async/animals/cat.rs create mode 100644 examples/async/animals/dog.rs create mode 100644 examples/async/animals/human.rs create mode 100644 examples/async/animals/mod.rs create mode 100644 examples/async/bootstrap.rs create mode 100644 examples/async/interfaces/cat.rs create mode 100644 examples/async/interfaces/dog.rs create mode 100644 examples/async/interfaces/human.rs create mode 100644 examples/async/interfaces/mod.rs create mode 100644 examples/async/main.rs (limited to 'examples/async') diff --git a/examples/async/animals/cat.rs b/examples/async/animals/cat.rs new file mode 100644 index 0000000..b1e6f27 --- /dev/null +++ b/examples/async/animals/cat.rs @@ -0,0 +1,22 @@ +use syrette::injectable; + +use crate::interfaces::cat::ICat; + +pub struct Cat {} + +#[injectable(ICat, { async = true })] +impl Cat +{ + pub fn new() -> Self + { + Self {} + } +} + +impl ICat for Cat +{ + fn meow(&self) + { + println!("Meow!"); + } +} diff --git a/examples/async/animals/dog.rs b/examples/async/animals/dog.rs new file mode 100644 index 0000000..d1b33f9 --- /dev/null +++ b/examples/async/animals/dog.rs @@ -0,0 +1,22 @@ +use syrette::injectable; + +use crate::interfaces::dog::IDog; + +pub struct Dog {} + +#[injectable(IDog, { async = true })] +impl Dog +{ + pub fn new() -> Self + { + Self {} + } +} + +impl IDog for Dog +{ + fn woof(&self) + { + println!("Woof!"); + } +} diff --git a/examples/async/animals/human.rs b/examples/async/animals/human.rs new file mode 100644 index 0000000..140f27c --- /dev/null +++ b/examples/async/animals/human.rs @@ -0,0 +1,36 @@ +use syrette::injectable; +use syrette::ptr::{ThreadsafeSingletonPtr, TransientPtr}; + +use crate::interfaces::cat::ICat; +use crate::interfaces::dog::IDog; +use crate::interfaces::human::IHuman; + +pub struct Human +{ + dog: ThreadsafeSingletonPtr, + cat: TransientPtr, +} + +#[injectable(IHuman, { async = true })] +impl Human +{ + pub fn new(dog: ThreadsafeSingletonPtr, cat: TransientPtr) + -> Self + { + Self { dog, cat } + } +} + +impl IHuman for Human +{ + fn make_pets_make_sounds(&self) + { + println!("Hi doggy!"); + + self.dog.woof(); + + println!("Hi kitty!"); + + self.cat.meow(); + } +} diff --git a/examples/async/animals/mod.rs b/examples/async/animals/mod.rs new file mode 100644 index 0000000..5444978 --- /dev/null +++ b/examples/async/animals/mod.rs @@ -0,0 +1,3 @@ +pub mod cat; +pub mod dog; +pub mod human; diff --git a/examples/async/bootstrap.rs b/examples/async/bootstrap.rs new file mode 100644 index 0000000..b640712 --- /dev/null +++ b/examples/async/bootstrap.rs @@ -0,0 +1,28 @@ +use anyhow::Result; +use syrette::async_di_container::AsyncDIContainer; + +// Concrete implementations +use crate::animals::cat::Cat; +use crate::animals::dog::Dog; +use crate::animals::human::Human; +// +// Interfaces +use crate::interfaces::cat::ICat; +use crate::interfaces::dog::IDog; +use crate::interfaces::human::IHuman; + +pub async fn bootstrap() -> Result +{ + let mut di_container = AsyncDIContainer::new(); + + di_container + .bind::() + .to::()? + .in_singleton_scope() + .await?; + + di_container.bind::().to::()?; + di_container.bind::().to::()?; + + Ok(di_container) +} diff --git a/examples/async/interfaces/cat.rs b/examples/async/interfaces/cat.rs new file mode 100644 index 0000000..478f7e0 --- /dev/null +++ b/examples/async/interfaces/cat.rs @@ -0,0 +1,4 @@ +pub trait ICat: Send + Sync +{ + fn meow(&self); +} diff --git a/examples/async/interfaces/dog.rs b/examples/async/interfaces/dog.rs new file mode 100644 index 0000000..a6ed111 --- /dev/null +++ b/examples/async/interfaces/dog.rs @@ -0,0 +1,4 @@ +pub trait IDog: Send + Sync +{ + fn woof(&self); +} diff --git a/examples/async/interfaces/human.rs b/examples/async/interfaces/human.rs new file mode 100644 index 0000000..18f9d63 --- /dev/null +++ b/examples/async/interfaces/human.rs @@ -0,0 +1,4 @@ +pub trait IHuman: Send + Sync +{ + fn make_pets_make_sounds(&self); +} diff --git a/examples/async/interfaces/mod.rs b/examples/async/interfaces/mod.rs new file mode 100644 index 0000000..5444978 --- /dev/null +++ b/examples/async/interfaces/mod.rs @@ -0,0 +1,3 @@ +pub mod cat; +pub mod dog; +pub mod human; diff --git a/examples/async/main.rs b/examples/async/main.rs new file mode 100644 index 0000000..f72ff39 --- /dev/null +++ b/examples/async/main.rs @@ -0,0 +1,52 @@ +#![deny(clippy::all)] +#![deny(clippy::pedantic)] +#![allow(clippy::module_name_repetitions)] + +use std::sync::Arc; + +use anyhow::Result; +use tokio::spawn; +use tokio::sync::Mutex; + +mod animals; +mod bootstrap; +mod interfaces; + +use bootstrap::bootstrap; +use interfaces::dog::IDog; +use interfaces::human::IHuman; + +#[tokio::main] +async fn main() -> Result<()> +{ + println!("Hello, world!"); + + let di_container = Arc::new(Mutex::new(bootstrap().await?)); + + { + let dog = di_container + .lock() + .await + .get::() + .await? + .threadsafe_singleton()?; + + dog.woof(); + } + + spawn(async move { + let human = di_container + .lock() + .await + .get::() + .await? + .transient()?; + + human.make_pets_make_sounds(); + + Ok::<_, anyhow::Error>(()) + }) + .await??; + + Ok(()) +} -- cgit v1.2.3-18-g5258