diff options
| author | HampusM <hampus@hampusmat.com> | 2023-08-04 22:03:30 +0200 | 
|---|---|---|
| committer | HampusM <hampus@hampusmat.com> | 2023-08-04 22:03:30 +0200 | 
| commit | b4718494e3a1759286caca1dd34c01db6c2f1214 (patch) | |
| tree | 736bde3a1647d7c26c7cc27ce3caf4de2fa665d8 /src/di_container | |
| parent | b4ddc1e626fbd11d784b442d246ddc5f54c35b51 (diff) | |
refactor!: remove SomeThreadsafePtr & move variants to SomePtr
BREAKING CHANGE: SomeThreadsafePtr has been removed and it's variants have been moved to SomePtr
Diffstat (limited to 'src/di_container')
| -rw-r--r-- | src/di_container/asynchronous/mod.rs | 44 | 
1 files changed, 20 insertions, 24 deletions
| diff --git a/src/di_container/asynchronous/mod.rs b/src/di_container/asynchronous/mod.rs index 19e28a8..b603e88 100644 --- a/src/di_container/asynchronous/mod.rs +++ b/src/di_container/asynchronous/mod.rs @@ -66,7 +66,7 @@ use crate::private::cast::arc::CastArc;  use crate::private::cast::boxed::CastBox;  use crate::private::cast::error::CastError;  use crate::provider::r#async::{AsyncProvidable, IAsyncProvider}; -use crate::ptr::{SomeThreadsafePtr, TransientPtr}; +use crate::ptr::{SomePtr, TransientPtr};  pub mod binding;  pub mod prelude; @@ -96,7 +96,7 @@ where      /// - Casting the binding for `Interface` fails      fn get<'a, 'b, Interface>(          self: &'a Arc<Self>, -    ) -> BoxFuture<'b, Result<SomeThreadsafePtr<Interface>, AsyncDIContainerError>> +    ) -> BoxFuture<'b, Result<SomePtr<Interface>, AsyncDIContainerError>>      where          Interface: 'static + 'b + ?Sized + Send + Sync,          'a: 'b, @@ -112,7 +112,7 @@ where      fn get_named<'a, 'b, Interface>(          self: &'a Arc<Self>,          name: &'static str, -    ) -> BoxFuture<'b, Result<SomeThreadsafePtr<Interface>, AsyncDIContainerError>> +    ) -> BoxFuture<'b, Result<SomePtr<Interface>, AsyncDIContainerError>>      where          Interface: 'static + 'b + ?Sized + Send + Sync,          'a: 'b, @@ -123,7 +123,7 @@ where          self: &Arc<Self>,          dependency_history: DependencyHistoryType,          name: Option<&'static str>, -    ) -> Result<SomeThreadsafePtr<Interface>, AsyncDIContainerError> +    ) -> Result<SomePtr<Interface>, AsyncDIContainerError>      where          Interface: 'static + ?Sized + Send + Sync;  } @@ -161,7 +161,7 @@ impl IAsyncDIContainer<DependencyHistory> for AsyncDIContainer      fn get<'a, 'b, Interface>(          self: &'a Arc<Self>, -    ) -> BoxFuture<'b, Result<SomeThreadsafePtr<Interface>, AsyncDIContainerError>> +    ) -> BoxFuture<'b, Result<SomePtr<Interface>, AsyncDIContainerError>>      where          Interface: 'static + 'b + ?Sized + Send + Sync,          'a: 'b, @@ -176,7 +176,7 @@ impl IAsyncDIContainer<DependencyHistory> for AsyncDIContainer      fn get_named<'a, 'b, Interface>(          self: &'a Arc<Self>,          name: &'static str, -    ) -> BoxFuture<'b, Result<SomeThreadsafePtr<Interface>, AsyncDIContainerError>> +    ) -> BoxFuture<'b, Result<SomePtr<Interface>, AsyncDIContainerError>>      where          Interface: 'static + 'b + ?Sized + Send + Sync,          'a: 'b, @@ -192,7 +192,7 @@ impl IAsyncDIContainer<DependencyHistory> for AsyncDIContainer          self: &Arc<Self>,          dependency_history: DependencyHistory,          name: Option<&'static str>, -    ) -> Result<SomeThreadsafePtr<Interface>, AsyncDIContainerError> +    ) -> Result<SomePtr<Interface>, AsyncDIContainerError>      where          Interface: 'static + ?Sized + Send + Sync,      { @@ -243,23 +243,21 @@ impl AsyncDIContainer      async fn handle_binding_providable<Interface>(          self: &Arc<Self>,          binding_providable: AsyncProvidable<Self, DependencyHistory>, -    ) -> Result<SomeThreadsafePtr<Interface>, AsyncDIContainerError> +    ) -> Result<SomePtr<Interface>, AsyncDIContainerError>      where          Interface: 'static + ?Sized + Send + Sync,      {          match binding_providable { -            AsyncProvidable::Transient(transient_binding) => { -                Ok(SomeThreadsafePtr::Transient( -                    transient_binding.cast::<Interface>().map_err(|_| { -                        AsyncDIContainerError::CastFailed { -                            interface: type_name::<Interface>(), -                            binding_kind: "transient", -                        } -                    })?, -                )) -            } +            AsyncProvidable::Transient(transient_binding) => Ok(SomePtr::Transient( +                transient_binding.cast::<Interface>().map_err(|_| { +                    AsyncDIContainerError::CastFailed { +                        interface: type_name::<Interface>(), +                        binding_kind: "transient", +                    } +                })?, +            )),              AsyncProvidable::Singleton(singleton_binding) => { -                Ok(SomeThreadsafePtr::ThreadsafeSingleton( +                Ok(SomePtr::ThreadsafeSingleton(                      singleton_binding                          .cast::<Interface>()                          .map_err(|err| match err { @@ -308,9 +306,7 @@ impl AsyncDIContainer                          }                      })?; -                Ok(SomeThreadsafePtr::ThreadsafeFactory( -                    factory(self.clone()).into(), -                )) +                Ok(SomePtr::ThreadsafeFactory(factory(self.clone()).into()))              }              #[cfg(feature = "factory")]              AsyncProvidable::DefaultFactory(binding) => { @@ -323,7 +319,7 @@ impl AsyncDIContainer                      >,                  >(binding, "default factory")?; -                Ok(SomeThreadsafePtr::Transient(default_factory(self.clone())())) +                Ok(SomePtr::Transient(default_factory(self.clone())()))              }              #[cfg(feature = "factory")]              AsyncProvidable::AsyncDefaultFactory(binding) => { @@ -340,7 +336,7 @@ impl AsyncDIContainer                      binding, "async default factory"                  )?; -                Ok(SomeThreadsafePtr::Transient( +                Ok(SomePtr::Transient(                      async_default_factory(self.clone())().await,                  ))              } | 
