ets-labs/python-dependency-injector
1
1
Fork 0
mirror of https://github.com/ets-labs/python-dependency-injector.git synced 2024-12-01 14:04:01 +03:00
Code Issues Packages Projects Releases Wiki Activity

Refactor Resource provider to use async mode api

Browse Source
This commit is contained in:
Roman Mogylatov 2021-01-01 22:50:27 -05:00
parent 2c911ff1f2
commit 141843e62f
4 changed files with 3088 additions and 3241 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1053
src/dependency_injector/containers.c
View File

File diff suppressed because it is too large Load Diff

5260
src/dependency_injector/providers.c
View File

File diff suppressed because it is too large Load Diff

1
src/dependency_injector/providers.pxd
View File

@ -202,7 +202,6 @@ cdef class Resource(Provider):
cdef bint __initialized
cdef object __shutdowner
cdef object __resource
cdef bint __async
cdef tuple __args
cdef int __args_len

15
src/dependency_injector/providers.pyx
View File

@ -2706,7 +2706,6 @@ cdef class Resource(Provider):
self.__initialized = False
self.__resource = None
self.__shutdowner = None
self.__async = False
self.__args = tuple()
self.__args_len = 0
@ -2838,7 +2837,7 @@ cdef class Resource(Provider):
def shutdown(self):
"""Shutdown resource."""
if not self.__initialized:
if self.__async:
if self.is_async_mode_enabled():
result = asyncio.Future()
result.set_result(None)
return result
@ -2857,20 +2856,13 @@ cdef class Resource(Provider):
self.__initialized = False
self.__shutdowner = None
if self.__async:
if self.is_async_mode_enabled():
result = asyncio.Future()
result.set_result(None)
return result
cpdef object _provide(self, tuple args, dict kwargs):
if self.__initialized:
if self.__async:
if __isawaitable(self.__resource):
return self.__resource
result = asyncio.Future()
result.set_result(self.__resource)
return result
return self.__resource
if self._is_resource_subclass(self.__initializer):
@ -2897,7 +2889,6 @@ cdef class Resource(Provider):
self.__kwargs_len,
)
self.__initialized = True
self.__async = True
return self._create_init_future(async_init, initializer.shutdown)
elif inspect.isgeneratorfunction(self.__initializer):
initializer = __call(
@ -2922,7 +2913,6 @@ cdef class Resource(Provider):
self.__kwargs_len,
)
self.__initialized = True
self.__async = True
return self._create_init_future(initializer)
elif isasyncgenfunction(self.__initializer):
initializer = __call(
@ -2935,7 +2925,6 @@ cdef class Resource(Provider):
self.__kwargs_len,
)
self.__initialized = True
self.__async = True
return self._create_init_future(initializer.__anext__(), initializer.asend)
elif callable(self.__initializer):
self.__resource = __call(