diff options
| author | HampusM <hampus@hampusmat.com> | 2023-09-18 22:35:58 +0200 | 
|---|---|---|
| committer | HampusM <hampus@hampusmat.com> | 2023-09-18 22:35:58 +0200 | 
| commit | 4fd0d6b4951b08a20d5378bca75561109dc6d036 (patch) | |
| tree | 8496d679e7ee3debcd415ed563911e2166594212 /src/di_container/asynchronous/binding | |
| parent | de2e1349f459f7f69226b2decd366be690426ea7 (diff) | |
refactor!: make the async DI container not inside a Arc
BREAKING CHANGE: The async DI container is no longer inside of a Arc. This affects AsyncBindingBuilder, AsyncBindingScopeConfigurator, AsyncBindingWhenConfigurator & AsyncInjectable
Diffstat (limited to 'src/di_container/asynchronous/binding')
3 files changed, 62 insertions, 52 deletions
| diff --git a/src/di_container/asynchronous/binding/builder.rs b/src/di_container/asynchronous/binding/builder.rs index c253929..acb1c69 100644 --- a/src/di_container/asynchronous/binding/builder.rs +++ b/src/di_container/asynchronous/binding/builder.rs @@ -1,7 +1,6 @@  //! Binding builder for types inside of a [`AsyncDIContainer`].  use std::any::type_name;  use std::marker::PhantomData; -use std::sync::Arc;  use crate::di_container::asynchronous::binding::scope_configurator::AsyncBindingScopeConfigurator;  #[cfg(feature = "factory")] @@ -21,22 +20,22 @@ pub type BoxFn<Args, Return> = Box<(dyn Fn<Args, Output = Return> + Send + Sync)  /// Binding builder for type `Interface` inside a [`AsyncDIContainer`].  #[must_use = "No binding will be created if you don't use the binding builder"] -pub struct AsyncBindingBuilder<Interface> +pub struct AsyncBindingBuilder<'di_container, Interface>  where      Interface: 'static + ?Sized + Send + Sync,  { -    di_container: Arc<AsyncDIContainer>, +    di_container: &'di_container AsyncDIContainer,      dependency_history_factory: fn() -> DependencyHistory,      interface_phantom: PhantomData<Interface>,  } -impl<Interface> AsyncBindingBuilder<Interface> +impl<'di_container, Interface> AsyncBindingBuilder<'di_container, Interface>  where      Interface: 'static + ?Sized + Send + Sync,  {      pub(crate) fn new( -        di_container: Arc<AsyncDIContainer>, +        di_container: &'di_container AsyncDIContainer,          dependency_history_factory: fn() -> DependencyHistory,      ) -> Self      { @@ -91,7 +90,7 @@ where      pub async fn to<Implementation>(          self,      ) -> Result< -        AsyncBindingScopeConfigurator<Interface, Implementation>, +        AsyncBindingScopeConfigurator<'di_container, Interface, Implementation>,          AsyncBindingBuilderError,      >      where @@ -109,7 +108,7 @@ where          }          let binding_scope_configurator = AsyncBindingScopeConfigurator::new( -            self.di_container.clone(), +            self.di_container,              self.dependency_history_factory,          ); @@ -170,13 +169,15 @@ where      pub async fn to_factory<Args, Return, FactoryFunc>(          self,          factory_func: &'static FactoryFunc, -    ) -> Result<AsyncBindingWhenConfigurator<Interface>, AsyncBindingBuilderError> +    ) -> Result< +        AsyncBindingWhenConfigurator<'di_container, Interface>, +        AsyncBindingBuilderError, +    >      where          Args: std::marker::Tuple + 'static,          Return: 'static + ?Sized,          Interface: Fn<Args, Output = Return> + Send + Sync, -        FactoryFunc: -            Fn<(Arc<AsyncDIContainer>,), Output = BoxFn<Args, Return>> + Send + Sync, +        FactoryFunc: Fn(&AsyncDIContainer) -> BoxFn<Args, Return> + Send + Sync,      {          use crate::private::castable_factory::threadsafe::ThreadsafeCastableFactory;          use crate::provider::r#async::AsyncFactoryVariant; @@ -204,7 +205,7 @@ where              )              .await; -        Ok(AsyncBindingWhenConfigurator::new(self.di_container.clone())) +        Ok(AsyncBindingWhenConfigurator::new(self.di_container))      }      /// Creates a binding of factory type `Interface` to a async factory inside of the @@ -268,16 +269,19 @@ where      pub async fn to_async_factory<Args, Return, FactoryFunc>(          self,          factory_func: &'static FactoryFunc, -    ) -> Result<AsyncBindingWhenConfigurator<Interface>, AsyncBindingBuilderError> +    ) -> Result< +        AsyncBindingWhenConfigurator<'di_container, Interface>, +        AsyncBindingBuilderError, +    >      where          Args: std::marker::Tuple + 'static,          Return: 'static + ?Sized,          Interface:              Fn<Args, Output = crate::future::BoxFuture<'static, Return>> + Send + Sync, -        FactoryFunc: Fn< -                (Arc<AsyncDIContainer>,), -                Output = BoxFn<Args, crate::future::BoxFuture<'static, Return>>, -            > + Send +        FactoryFunc: Fn( +                &AsyncDIContainer, +            ) -> BoxFn<Args, crate::future::BoxFuture<'static, Return>> +            + Send              + Sync,      {          use crate::private::castable_factory::threadsafe::ThreadsafeCastableFactory; @@ -306,7 +310,7 @@ where              )              .await; -        Ok(AsyncBindingWhenConfigurator::new(self.di_container.clone())) +        Ok(AsyncBindingWhenConfigurator::new(self.di_container))      }      /// Creates a binding of type `Interface` to a factory that takes no arguments @@ -360,13 +364,14 @@ where      pub async fn to_default_factory<Return, FactoryFunc>(          self,          factory_func: &'static FactoryFunc, -    ) -> Result<AsyncBindingWhenConfigurator<Interface>, AsyncBindingBuilderError> +    ) -> Result< +        AsyncBindingWhenConfigurator<'di_container, Interface>, +        AsyncBindingBuilderError, +    >      where          Return: 'static + ?Sized, -        FactoryFunc: Fn< -                (Arc<AsyncDIContainer>,), -                Output = BoxFn<(), crate::ptr::TransientPtr<Return>>, -            > + Send +        FactoryFunc: Fn(&AsyncDIContainer) -> BoxFn<(), crate::ptr::TransientPtr<Return>> +            + Send              + Sync,      {          use crate::private::castable_factory::threadsafe::ThreadsafeCastableFactory; @@ -395,7 +400,7 @@ where              )              .await; -        Ok(AsyncBindingWhenConfigurator::new(self.di_container.clone())) +        Ok(AsyncBindingWhenConfigurator::new(self.di_container))      }      /// Creates a binding of factory type `Interface` to a async factory inside of the @@ -454,13 +459,14 @@ where      pub async fn to_async_default_factory<Return, FactoryFunc>(          self,          factory_func: &'static FactoryFunc, -    ) -> Result<AsyncBindingWhenConfigurator<Interface>, AsyncBindingBuilderError> +    ) -> Result< +        AsyncBindingWhenConfigurator<'di_container, Interface>, +        AsyncBindingBuilderError, +    >      where          Return: 'static + ?Sized, -        FactoryFunc: Fn< -                (Arc<AsyncDIContainer>,), -                Output = BoxFn<(), crate::future::BoxFuture<'static, Return>>, -            > + Send +        FactoryFunc: Fn(&AsyncDIContainer) -> BoxFn<(), crate::future::BoxFuture<'static, Return>> +            + Send              + Sync,      {          use crate::private::castable_factory::threadsafe::ThreadsafeCastableFactory; @@ -489,7 +495,7 @@ where              )              .await; -        Ok(AsyncBindingWhenConfigurator::new(self.di_container.clone())) +        Ok(AsyncBindingWhenConfigurator::new(self.di_container))      }  } @@ -524,7 +530,7 @@ mod tests          let binding_builder =              AsyncBindingBuilder::<dyn subjects_async::IUserManager>::new( -                Arc::new(di_container_mock), +                &di_container_mock,                  MockDependencyHistory::new,              ); @@ -565,7 +571,7 @@ mod tests              .once();          let binding_builder = AsyncBindingBuilder::<IUserManagerFactory>::new( -            Arc::new(di_container_mock), +            &di_container_mock,              MockDependencyHistory::new,          ); @@ -614,7 +620,7 @@ mod tests              .once();          let binding_builder = AsyncBindingBuilder::<IUserManagerFactory>::new( -            Arc::new(di_container_mock), +            &di_container_mock,              MockDependencyHistory::new,          ); @@ -659,7 +665,7 @@ mod tests          let binding_builder =              AsyncBindingBuilder::<dyn subjects_async::IUserManager>::new( -                Arc::new(di_container_mock), +                &di_container_mock,                  MockDependencyHistory::new,              ); @@ -705,7 +711,7 @@ mod tests          let binding_builder =              AsyncBindingBuilder::<dyn subjects_async::IUserManager>::new( -                Arc::new(di_container_mock), +                &di_container_mock,                  MockDependencyHistory::new,              ); diff --git a/src/di_container/asynchronous/binding/scope_configurator.rs b/src/di_container/asynchronous/binding/scope_configurator.rs index 3557202..f079234 100644 --- a/src/di_container/asynchronous/binding/scope_configurator.rs +++ b/src/di_container/asynchronous/binding/scope_configurator.rs @@ -1,6 +1,5 @@  //! Scope configurator for a binding for types inside of a [`AsyncDIContainer`].  use std::marker::PhantomData; -use std::sync::Arc;  use crate::di_container::asynchronous::binding::when_configurator::AsyncBindingWhenConfigurator;  use crate::di_container::BindingOptions; @@ -14,25 +13,26 @@ use_double!(crate::dependency_history::DependencyHistory);  use_double!(crate::di_container::asynchronous::AsyncDIContainer);  /// Scope configurator for a binding for type `Interface` inside a [`AsyncDIContainer`]. -pub struct AsyncBindingScopeConfigurator<Interface, Implementation> +pub struct AsyncBindingScopeConfigurator<'di_container, Interface, Implementation>  where      Interface: 'static + ?Sized + Send + Sync,      Implementation: AsyncInjectable<AsyncDIContainer>,  { -    di_container: Arc<AsyncDIContainer>, +    di_container: &'di_container AsyncDIContainer,      dependency_history_factory: fn() -> DependencyHistory,      interface_phantom: PhantomData<Interface>,      implementation_phantom: PhantomData<Implementation>,  } -impl<Interface, Implementation> AsyncBindingScopeConfigurator<Interface, Implementation> +impl<'di_container, Interface, Implementation> +    AsyncBindingScopeConfigurator<'di_container, Interface, Implementation>  where      Interface: 'static + ?Sized + Send + Sync,      Implementation: AsyncInjectable<AsyncDIContainer>,  {      pub(crate) fn new( -        di_container: Arc<AsyncDIContainer>, +        di_container: &'di_container AsyncDIContainer,          dependency_history_factory: fn() -> DependencyHistory,      ) -> Self      { @@ -47,11 +47,13 @@ where      /// Configures the binding to be in a transient scope.      ///      /// This is the default. -    pub async fn in_transient_scope(self) -> AsyncBindingWhenConfigurator<Interface> +    pub async fn in_transient_scope( +        self, +    ) -> AsyncBindingWhenConfigurator<'di_container, Interface>      {          self.set_in_transient_scope().await; -        AsyncBindingWhenConfigurator::new(self.di_container.clone()) +        AsyncBindingWhenConfigurator::new(self.di_container)      }      /// Configures the binding to be in a singleton scope. @@ -60,12 +62,15 @@ where      /// Will return Err if resolving the implementation fails.      pub async fn in_singleton_scope(          self, -    ) -> Result<AsyncBindingWhenConfigurator<Interface>, AsyncBindingScopeConfiguratorError> +    ) -> Result< +        AsyncBindingWhenConfigurator<'di_container, Interface>, +        AsyncBindingScopeConfiguratorError, +    >      {          let singleton: ThreadsafeSingletonPtr<Implementation> =              ThreadsafeSingletonPtr::from(                  Implementation::resolve( -                    &self.di_container, +                    self.di_container,                      (self.dependency_history_factory)(),                  )                  .await @@ -79,7 +84,7 @@ where              )              .await; -        Ok(AsyncBindingWhenConfigurator::new(self.di_container.clone())) +        Ok(AsyncBindingWhenConfigurator::new(self.di_container))      }      pub(crate) async fn set_in_transient_scope(&self) @@ -118,7 +123,7 @@ mod tests              AsyncBindingScopeConfigurator::<                  dyn subjects_async::IUserManager,                  subjects_async::UserManager, -            >::new(Arc::new(di_container_mock), MockDependencyHistory::new); +            >::new(&di_container_mock, MockDependencyHistory::new);          binding_scope_configurator.in_transient_scope().await;      } @@ -138,7 +143,7 @@ mod tests              AsyncBindingScopeConfigurator::<                  dyn subjects_async::IUserManager,                  subjects_async::UserManager, -            >::new(Arc::new(di_container_mock), MockDependencyHistory::new); +            >::new(&di_container_mock, MockDependencyHistory::new);          assert!(binding_scope_configurator              .in_singleton_scope() diff --git a/src/di_container/asynchronous/binding/when_configurator.rs b/src/di_container/asynchronous/binding/when_configurator.rs index 3c1de7c..b7c2767 100644 --- a/src/di_container/asynchronous/binding/when_configurator.rs +++ b/src/di_container/asynchronous/binding/when_configurator.rs @@ -1,7 +1,6 @@  //! When configurator for a binding for types inside of a [`AsyncDIContainer`].  use std::any::type_name;  use std::marker::PhantomData; -use std::sync::Arc;  use crate::di_container::BindingOptions;  use crate::errors::async_di_container::AsyncBindingWhenConfiguratorError; @@ -10,20 +9,20 @@ use crate::util::use_double;  use_double!(crate::di_container::asynchronous::AsyncDIContainer);  /// When configurator for a binding for type `Interface` inside a [`AsyncDIContainer`]. -pub struct AsyncBindingWhenConfigurator<Interface> +pub struct AsyncBindingWhenConfigurator<'di_container, Interface>  where      Interface: 'static + ?Sized + Send + Sync,  { -    di_container: Arc<AsyncDIContainer>, +    di_container: &'di_container AsyncDIContainer,      interface_phantom: PhantomData<Interface>,  } -impl<Interface> AsyncBindingWhenConfigurator<Interface> +impl<'di_container, Interface> AsyncBindingWhenConfigurator<'di_container, Interface>  where      Interface: 'static + ?Sized + Send + Sync,  { -    pub(crate) fn new(di_container: Arc<AsyncDIContainer>) -> Self +    pub(crate) fn new(di_container: &'di_container AsyncDIContainer) -> Self      {          Self {              di_container, @@ -90,7 +89,7 @@ mod tests          let binding_when_configurator = AsyncBindingWhenConfigurator::<              dyn subjects_async::INumber, -        >::new(Arc::new(di_container_mock)); +        >::new(&di_container_mock);          assert!(binding_when_configurator              .when_named("awesome") | 
