Matej Cepl
52a1a730b1
* Update Notebooks: Part One by @J0 * Update get_started.rst * docs: fix miss typed operator name * Fix flake8 in pre-commit * fix(docs): IO Concurrency for 3.10+ * Concat map * Docs on testing * [DOCS] Getting started: fix example * Update pyright to 1.1.286 * Add CI check for Python-3.11 * Switchmap operator * Fix deprecated calls to datetime by @ricardobranco777 * CI: Update used actions and Python versions * Fix build * Drop Python 3.8 support * Support Python 3.11, 3.12 and 3.13 - Added fix-python314-test.patch: Fix tests to be compatible with Python3.14 until new version release OBS-URL: https://build.opensuse.org/package/show/devel:languages:python/python-reactivex?expand=0&rev=5
335 lines
12 KiB
Diff
335 lines
12 KiB
Diff
Index: RxPY-4.1.0/tests/test_observable/test_flatmap_async.py
|
|
===================================================================
|
|
--- RxPY-4.1.0.orig/tests/test_observable/test_flatmap_async.py
|
|
+++ RxPY-4.1.0/tests/test_observable/test_flatmap_async.py
|
|
@@ -9,7 +9,11 @@ from reactivex.subject import Subject
|
|
class TestFlatMapAsync(unittest.TestCase):
|
|
def test_flat_map_async(self):
|
|
actual_next = None
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
scheduler = AsyncIOScheduler(loop=loop)
|
|
|
|
def mapper(i: int):
|
|
Index: RxPY-4.1.0/tests/test_observable/test_fromfuture.py
|
|
===================================================================
|
|
--- RxPY-4.1.0.orig/tests/test_observable/test_fromfuture.py
|
|
+++ RxPY-4.1.0/tests/test_observable/test_fromfuture.py
|
|
@@ -7,7 +7,11 @@ import reactivex
|
|
|
|
class TestFromFuture(unittest.TestCase):
|
|
def test_future_success(self):
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
success = [False, True, False]
|
|
|
|
async def go():
|
|
@@ -31,7 +35,11 @@ class TestFromFuture(unittest.TestCase):
|
|
assert all(success)
|
|
|
|
def test_future_failure(self):
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
success = [True, False, True]
|
|
|
|
async def go():
|
|
@@ -57,7 +65,11 @@ class TestFromFuture(unittest.TestCase):
|
|
assert all(success)
|
|
|
|
def test_future_cancel(self):
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
success = [True, False, True]
|
|
|
|
async def go():
|
|
@@ -80,7 +92,11 @@ class TestFromFuture(unittest.TestCase):
|
|
assert all(success)
|
|
|
|
def test_future_dispose(self):
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
success = [True, True, True]
|
|
|
|
async def go():
|
|
Index: RxPY-4.1.0/tests/test_observable/test_start.py
|
|
===================================================================
|
|
--- RxPY-4.1.0.orig/tests/test_observable/test_start.py
|
|
+++ RxPY-4.1.0/tests/test_observable/test_start.py
|
|
@@ -16,7 +16,11 @@ created = ReactiveTest.created
|
|
|
|
class TestStart(unittest.TestCase):
|
|
def test_start_async(self):
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
success = [False]
|
|
|
|
async def go():
|
|
@@ -36,7 +40,11 @@ class TestStart(unittest.TestCase):
|
|
assert all(success)
|
|
|
|
def test_start_async_error(self):
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
success = [False]
|
|
|
|
async def go():
|
|
Index: RxPY-4.1.0/tests/test_observable/test_tofuture.py
|
|
===================================================================
|
|
--- RxPY-4.1.0.orig/tests/test_observable/test_tofuture.py
|
|
+++ RxPY-4.1.0/tests/test_observable/test_tofuture.py
|
|
@@ -18,7 +18,11 @@ created = ReactiveTest.created
|
|
|
|
class TestToFuture(unittest.TestCase):
|
|
def test_await_success(self):
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
result = None
|
|
|
|
async def go():
|
|
@@ -30,7 +34,11 @@ class TestToFuture(unittest.TestCase):
|
|
assert result == 42
|
|
|
|
def test_await_success_on_sequence(self):
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
result = None
|
|
|
|
async def go():
|
|
@@ -42,7 +50,11 @@ class TestToFuture(unittest.TestCase):
|
|
assert result == 42
|
|
|
|
def test_await_error(self):
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
error = Exception("error")
|
|
result = None
|
|
|
|
@@ -58,7 +70,11 @@ class TestToFuture(unittest.TestCase):
|
|
assert result == error
|
|
|
|
def test_await_empty_observable(self):
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
result = None
|
|
|
|
async def go():
|
|
@@ -71,7 +87,11 @@ class TestToFuture(unittest.TestCase):
|
|
)
|
|
|
|
def test_await_with_delay(self):
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
result = None
|
|
|
|
async def go():
|
|
@@ -83,7 +103,11 @@ class TestToFuture(unittest.TestCase):
|
|
assert result == 42
|
|
|
|
def test_cancel(self):
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
|
|
async def go():
|
|
source = reactivex.return_value(42)
|
|
@@ -96,7 +120,11 @@ class TestToFuture(unittest.TestCase):
|
|
self.assertRaises(asyncio.CancelledError, loop.run_until_complete, go())
|
|
|
|
def test_dispose_on_cancel(self):
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
sub = Subject()
|
|
|
|
async def using_sub():
|
|
Index: RxPY-4.1.0/tests/test_scheduler/test_eventloop/test_asyncioscheduler.py
|
|
===================================================================
|
|
--- RxPY-4.1.0.orig/tests/test_scheduler/test_eventloop/test_asyncioscheduler.py
|
|
+++ RxPY-4.1.0/tests/test_scheduler/test_eventloop/test_asyncioscheduler.py
|
|
@@ -13,14 +13,22 @@ CI = os.getenv("CI") is not None
|
|
class TestAsyncIOScheduler(unittest.TestCase):
|
|
@pytest.mark.skipif(CI, reason="Flaky test in GitHub Actions")
|
|
def test_asyncio_schedule_now(self):
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
scheduler = AsyncIOScheduler(loop)
|
|
diff = scheduler.now - datetime.fromtimestamp(loop.time(), tz=timezone.utc)
|
|
assert abs(diff) < timedelta(milliseconds=2) # NOTE: may take 1 ms in CI
|
|
|
|
@pytest.mark.skipif(CI, reason="Test is flaky in GitHub Actions")
|
|
def test_asyncio_schedule_now_units(self):
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
scheduler = AsyncIOScheduler(loop)
|
|
diff = scheduler.now
|
|
yield from asyncio.sleep(0.1)
|
|
@@ -28,7 +36,11 @@ class TestAsyncIOScheduler(unittest.Test
|
|
assert timedelta(milliseconds=80) < diff < timedelta(milliseconds=180)
|
|
|
|
def test_asyncio_schedule_action(self):
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
|
|
async def go():
|
|
scheduler = AsyncIOScheduler(loop)
|
|
@@ -46,7 +58,11 @@ class TestAsyncIOScheduler(unittest.Test
|
|
loop.run_until_complete(go())
|
|
|
|
def test_asyncio_schedule_action_due(self):
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
|
|
async def go():
|
|
scheduler = AsyncIOScheduler(loop)
|
|
@@ -67,7 +83,11 @@ class TestAsyncIOScheduler(unittest.Test
|
|
loop.run_until_complete(go())
|
|
|
|
def test_asyncio_schedule_action_cancel(self):
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
|
|
async def go():
|
|
ran = False
|
|
Index: RxPY-4.1.0/tests/test_scheduler/test_eventloop/test_asynciothreadsafescheduler.py
|
|
===================================================================
|
|
--- RxPY-4.1.0.orig/tests/test_scheduler/test_eventloop/test_asynciothreadsafescheduler.py
|
|
+++ RxPY-4.1.0/tests/test_scheduler/test_eventloop/test_asynciothreadsafescheduler.py
|
|
@@ -14,14 +14,22 @@ CI = os.getenv("CI") is not None
|
|
class TestAsyncIOThreadSafeScheduler(unittest.TestCase):
|
|
@pytest.mark.skipif(CI, reason="Flaky test in GitHub Actions")
|
|
def test_asyncio_threadsafe_schedule_now(self):
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
scheduler = AsyncIOThreadSafeScheduler(loop)
|
|
diff = scheduler.now - datetime.fromtimestamp(loop.time(), tz=timezone.utc)
|
|
assert abs(diff) < timedelta(milliseconds=2)
|
|
|
|
@pytest.mark.skipif(CI, reason="Flaky test in GitHub Actions")
|
|
def test_asyncio_threadsafe_schedule_now_units(self):
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
scheduler = AsyncIOThreadSafeScheduler(loop)
|
|
diff = scheduler.now
|
|
yield from asyncio.sleep(0.1)
|
|
@@ -29,7 +37,11 @@ class TestAsyncIOThreadSafeScheduler(uni
|
|
assert timedelta(milliseconds=80) < diff < timedelta(milliseconds=180)
|
|
|
|
def test_asyncio_threadsafe_schedule_action(self):
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
|
|
async def go():
|
|
scheduler = AsyncIOThreadSafeScheduler(loop)
|
|
@@ -50,7 +62,11 @@ class TestAsyncIOThreadSafeScheduler(uni
|
|
loop.run_until_complete(go())
|
|
|
|
def test_asyncio_threadsafe_schedule_action_due(self):
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
|
|
async def go():
|
|
scheduler = AsyncIOThreadSafeScheduler(loop)
|
|
@@ -74,7 +90,11 @@ class TestAsyncIOThreadSafeScheduler(uni
|
|
loop.run_until_complete(go())
|
|
|
|
def test_asyncio_threadsafe_schedule_action_cancel(self):
|
|
- loop = asyncio.get_event_loop()
|
|
+ try:
|
|
+ loop = asyncio.get_running_loop()
|
|
+ except RuntimeError:
|
|
+ loop = asyncio.new_event_loop()
|
|
+ asyncio.set_event_loop(loop)
|
|
|
|
async def go():
|
|
ran = False
|