@@ -1780,27 +1780,30 @@ async def func():
1780
1780
return 42
1781
1781
1782
1782
memoized = MemoizedMutex (func )
1783
- task1 = asyncio .create_task (memoized ())
1784
- task2 = asyncio .create_task (memoized ())
1785
- task3 = asyncio .create_task (memoized ())
1783
+ loop = asyncio .get_event_loop ()
1784
+
1785
+ task1 = loop .create_task (memoized ())
1786
+ task2 = loop .create_task (memoized ())
1787
+ task3 = loop .create_task (memoized ())
1786
1788
1787
1789
self .assertEqual (await task1 , 42 )
1788
1790
self .assertEqual (await task2 , 42 )
1789
1791
self .assertEqual (await task3 , 42 )
1790
1792
1791
-
1792
1793
@async_test
1793
1794
async def test_usage_after_resolve (self ):
1794
1795
async def func ():
1795
1796
await asyncio .sleep (0 )
1796
1797
return 42
1797
1798
1798
1799
memoized = MemoizedMutex (func )
1799
- task1 = asyncio .create_task (memoized ())
1800
+ loop = asyncio .get_event_loop ()
1801
+
1802
+ task1 = loop .create_task (memoized ())
1800
1803
self .assertEqual (await task1 , 42 )
1801
1804
1802
- task2 = asyncio .create_task (memoized ())
1803
- task3 = asyncio .create_task (memoized ())
1805
+ task2 = loop .create_task (memoized ())
1806
+ task3 = loop .create_task (memoized ())
1804
1807
self .assertEqual (await task2 , 42 )
1805
1808
self .assertEqual (await task3 , 42 )
1806
1809
0 commit comments