Script 'mail_helper' called by obssrc
Hello community,
here is the log from the commit of package python-reactivex for
openSUSE:Factory checked in at 2025-12-01 11:13:50
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
Comparing /work/SRC/openSUSE:Factory/python-reactivex (Old)
and /work/SRC/openSUSE:Factory/.python-reactivex.new.14147 (New)
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
Package is "python-reactivex"
Mon Dec 1 11:13:50 2025 rev:3 rq:1320598 version:4.1.0
Changes:
--------
--- /work/SRC/openSUSE:Factory/python-reactivex/python-reactivex.changes
2025-03-12 20:14:51.102362081 +0100
+++
/work/SRC/openSUSE:Factory/.python-reactivex.new.14147/python-reactivex.changes
2025-12-01 11:14:27.501394265 +0100
@@ -1,0 +2,22 @@
+Thu Nov 27 17:47:25 UTC 2025 - Marius Grossu <[email protected]>
+
+- Upadate to version 4.1.0:
+ * 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
+
+-------------------------------------------------------------------
Old:
----
reactivex-4.0.4-gh.tar.gz
New:
----
fix-python314-test.patch
reactivex-4.1.0-gh.tar.gz
----------(New B)----------
New: * 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
----------(New E)----------
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
Other differences:
------------------
++++++ python-reactivex.spec ++++++
--- /var/tmp/diff_new_pack.PuegMp/_old 2025-12-01 11:14:28.073418480 +0100
+++ /var/tmp/diff_new_pack.PuegMp/_new 2025-12-01 11:14:28.077418649 +0100
@@ -1,7 +1,7 @@
#
# spec file for package python-reactivex
#
-# Copyright (c) 2025 SUSE LLC
+# Copyright (c) 2025 SUSE LLC and contributors
#
# All modifications and additions to the file contributed by third parties
# remain the property of their copyright owners, unless otherwise agreed
@@ -18,13 +18,15 @@
%{?sle15_python_module_pythons}
Name: python-reactivex
-Version: 4.0.4
+Version: 4.1.0
Release: 0
Summary: ReactiveX (Rx) for Python
License: MIT
URL: https://reactivex.io
# SourceRepository: https://github.com/ReactiveX/RxPY
Source:
https://github.com/ReactiveX/RxPY/archive/refs/tags/v%{version}.tar.gz#/reactivex-%{version}-gh.tar.gz
+#PATCH-FIX-OPENSUSE fix-python314-test.patch
+Patch0: fix-python314-test.patch
BuildRequires: %{python_module base >= 3.7}
BuildRequires: %{python_module pip}
BuildRequires: %{python_module poetry-core >= 1.0.0}
++++++ fix-python314-test.patch ++++++
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
++++++ reactivex-4.0.4-gh.tar.gz -> reactivex-4.1.0-gh.tar.gz ++++++
++++ 6144 lines of diff (skipped)
