From 0fd5ec1980375ce4a7bfe47524a1eb1120d9529c Mon Sep 17 00:00:00 2001 From: "github-actions[bot]" <41898282+github-actions[bot]@users.noreply.github.com> Date: Fri, 1 May 2026 04:52:50 +0000 Subject: [PATCH 1/3] test: fix pyright strict-mode errors in tests/test_observable/ (batch 3) Fix pyright errors in 25 test files in tests/test_observable/: - Add 'from typing import NoReturn' import - Annotate '_raise' functions with 'ex: Exception -> NoReturn' signature - Fix callsites passing str to '_raise()' to wrap in Exception() - Fix subscribe functions returning 'lambda: None' to return Disposable() - Fix 'return dispose' to 'return Disposable(dispose)' - Fix 'o.on_error(str)' calls to wrap strings in Exception() - Fix 'do_action(on_next=action)' with zero-param action to accept one param - Remove non-None return values from 'finally_action' callbacks These changes allow tests/test_observable/ to eventually be removed from the pyright exclude list in pyproject.toml. Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com> --- tests/test_observable/test_bufferwithcount.py | 3 ++- tests/test_observable/test_create.py | 26 ++++++++++--------- tests/test_observable/test_debounce.py | 3 ++- tests/test_observable/test_defer.py | 3 ++- tests/test_observable/test_delay.py | 3 ++- tests/test_observable/test_delaywithmapper.py | 3 ++- tests/test_observable/test_distinct.py | 3 ++- .../test_distinctuntilchanged.py | 7 ++--- tests/test_observable/test_expand.py | 3 ++- tests/test_observable/test_finally.py | 4 --- tests/test_observable/test_firstordefault.py | 3 ++- tests/test_observable/test_fromcallback.py | 3 ++- tests/test_observable/test_fromiterable.py | 5 ++-- .../test_generatewithrelativetime.py | 15 ++++++----- tests/test_observable/test_last.py | 3 ++- tests/test_observable/test_merge.py | 2 +- tests/test_observable/test_minby.py | 7 ++--- tests/test_observable/test_publish.py | 3 ++- tests/test_observable/test_returnvalue.py | 3 ++- tests/test_observable/test_single.py | 3 ++- tests/test_observable/test_singleordefault.py | 3 ++- .../test_observable/test_takeuntilwithtime.py | 3 ++- tests/test_observable/test_timeout.py | 3 ++- .../test_observable/test_timeoutwithmapper.py | 3 ++- tests/test_observable/test_using.py | 7 ++--- 25 files changed, 72 insertions(+), 52 deletions(-) diff --git a/tests/test_observable/test_bufferwithcount.py b/tests/test_observable/test_bufferwithcount.py index 6bc10cfec..d07424ba6 100644 --- a/tests/test_observable/test_bufferwithcount.py +++ b/tests/test_observable/test_bufferwithcount.py @@ -1,4 +1,5 @@ import unittest +from typing import NoReturn from reactivex import operators as ops from reactivex.testing import ReactiveTest, TestScheduler @@ -17,7 +18,7 @@ class RxException(Exception): # Helper function for raising exceptions within lambdas -def _raise(ex): +def _raise(ex: Exception) -> NoReturn: raise RxException(ex) diff --git a/tests/test_observable/test_create.py b/tests/test_observable/test_create.py index e26715d3f..0a85c34be 100644 --- a/tests/test_observable/test_create.py +++ b/tests/test_observable/test_create.py @@ -1,6 +1,8 @@ import unittest +from typing import NoReturn import reactivex +from reactivex.disposable import Disposable from reactivex.testing import ReactiveTest, TestScheduler on_next = ReactiveTest.on_next @@ -17,7 +19,7 @@ class RxException(Exception): # Helper function for raising exceptions within lambdas -def _raise(ex): +def _raise(ex: str) -> NoReturn: raise RxException(ex) @@ -29,7 +31,7 @@ def _create(): def subscribe(o, scheduler=None): o.on_next(1) o.on_next(2) - return lambda: None + return Disposable() return reactivex.create(subscribe) @@ -43,9 +45,9 @@ def _create(): def subscribe(o, scheduler=None): o.on_completed() o.on_next(100) - o.on_error("ex") + o.on_error(Exception("ex")) o.on_completed() - return lambda: None + return Disposable() return reactivex.create(subscribe) @@ -58,11 +60,11 @@ def test_create_error(self): def _create(): def subscribe(o, scheduler=None): - o.on_error(ex) + o.on_error(Exception(ex)) o.on_next(100) - o.on_error("foo") + o.on_error(Exception("foo")) o.on_completed() - return lambda: None + return Disposable() return reactivex.create(subscribe) @@ -109,7 +111,7 @@ def action4(scheduler, state): def dispose(): is_stopped[0] = True - return dispose + return Disposable(dispose) return reactivex.create(subscribe) @@ -124,21 +126,21 @@ def dispose(): def test_create_observer_throws(self): def subscribe(o, scheduler=None): o.on_next(1) - return lambda: None + return Disposable() with self.assertRaises(RxException): reactivex.create(subscribe).subscribe(lambda x: _raise("ex")) def subscribe2(o, scheduler=None): - o.on_error("exception") - return lambda: None + o.on_error(Exception("exception")) + return Disposable() with self.assertRaises(RxException): reactivex.create(subscribe2).subscribe(on_error=lambda ex: _raise("ex")) def subscribe3(o, scheduler=None): o.on_completed() - return lambda: None + return Disposable() with self.assertRaises(RxException): reactivex.create(subscribe3).subscribe(on_completed=lambda: _raise("ex")) diff --git a/tests/test_observable/test_debounce.py b/tests/test_observable/test_debounce.py index 9f61195d4..cc1d7300a 100644 --- a/tests/test_observable/test_debounce.py +++ b/tests/test_observable/test_debounce.py @@ -1,4 +1,5 @@ import unittest +from typing import NoReturn from reactivex import empty, never, throw from reactivex import operators as _ @@ -18,7 +19,7 @@ class RxException(Exception): # Helper function for raising exceptions within lambdas -def _raise(ex): +def _raise(ex: Exception) -> NoReturn: raise RxException(ex) diff --git a/tests/test_observable/test_defer.py b/tests/test_observable/test_defer.py index 669fbf406..10d22f38e 100644 --- a/tests/test_observable/test_defer.py +++ b/tests/test_observable/test_defer.py @@ -1,4 +1,5 @@ import unittest +from typing import NoReturn import reactivex from reactivex.testing import ReactiveTest, TestScheduler @@ -18,7 +19,7 @@ class RxException(Exception): # Helper function for raising exceptions within lambdas -def _raise(ex): +def _raise(ex: Exception) -> NoReturn: raise RxException(ex) diff --git a/tests/test_observable/test_delay.py b/tests/test_observable/test_delay.py index d11000bb9..a37de53a5 100644 --- a/tests/test_observable/test_delay.py +++ b/tests/test_observable/test_delay.py @@ -1,5 +1,6 @@ import logging import unittest +from typing import NoReturn from datetime import datetime, timezone from reactivex.operators import delay @@ -23,7 +24,7 @@ class RxException(Exception): # Helper function for raising exceptions within lambdas -def _raise(ex): +def _raise(ex: Exception) -> NoReturn: raise RxException(ex) diff --git a/tests/test_observable/test_delaywithmapper.py b/tests/test_observable/test_delaywithmapper.py index cfe8da95b..f74e7dbd1 100644 --- a/tests/test_observable/test_delaywithmapper.py +++ b/tests/test_observable/test_delaywithmapper.py @@ -1,4 +1,5 @@ import unittest +from typing import NoReturn from reactivex import Observable, abc from reactivex import operators as ops @@ -20,7 +21,7 @@ class RxException(Exception): # Helper function for raising exceptions within lambdas -def _raise(ex): +def _raise(ex: Exception) -> NoReturn: raise RxException(ex) diff --git a/tests/test_observable/test_distinct.py b/tests/test_observable/test_distinct.py index a5a725f55..edfbe9415 100644 --- a/tests/test_observable/test_distinct.py +++ b/tests/test_observable/test_distinct.py @@ -1,5 +1,6 @@ import math import unittest +from typing import NoReturn from reactivex import operators as ops from reactivex.testing import ReactiveTest, TestScheduler @@ -18,7 +19,7 @@ class RxException(Exception): # Helper function for raising exceptions within lambdas -def _raise(ex): +def _raise(ex: Exception) -> NoReturn: raise RxException(ex) diff --git a/tests/test_observable/test_distinctuntilchanged.py b/tests/test_observable/test_distinctuntilchanged.py index dae0220da..26254f0b3 100644 --- a/tests/test_observable/test_distinctuntilchanged.py +++ b/tests/test_observable/test_distinctuntilchanged.py @@ -1,4 +1,5 @@ import unittest +from typing import NoReturn import reactivex from reactivex import operators as ops @@ -18,7 +19,7 @@ class RxException(Exception): # Helper function for raising exceptions within lambdas -def _raise(ex): +def _raise(ex: Exception) -> NoReturn: raise RxException(ex) @@ -282,7 +283,7 @@ def test_distinct_until_changed_key_mapper_throws(self): ) def create(): - return xs.pipe(ops.distinct_until_changed(lambda x: _raise(ex))) + return xs.pipe(ops.distinct_until_changed(lambda x: _raise(Exception(ex)))) results = scheduler.start(create) assert results.messages == [on_error(210, ex)] @@ -296,7 +297,7 @@ def test_distinct_until_changed_comparer_throws(self): def create(): return xs.pipe( - ops.distinct_until_changed(comparer=lambda x, y: _raise(ex)), + ops.distinct_until_changed(comparer=lambda x, y: _raise(Exception(ex))), ) results = scheduler.start(create) diff --git a/tests/test_observable/test_expand.py b/tests/test_observable/test_expand.py index 0fa7d315d..05462fc94 100644 --- a/tests/test_observable/test_expand.py +++ b/tests/test_observable/test_expand.py @@ -1,4 +1,5 @@ import unittest +from typing import NoReturn from reactivex import operators as ops from reactivex.testing import ReactiveTest, TestScheduler @@ -17,7 +18,7 @@ class RxException(Exception): # Helper function for raising exceptions within lambdas -def _raise(ex): +def _raise(ex: Exception) -> NoReturn: raise RxException(ex) diff --git a/tests/test_observable/test_finally.py b/tests/test_observable/test_finally.py index 69e7cd51d..7d920e062 100644 --- a/tests/test_observable/test_finally.py +++ b/tests/test_observable/test_finally.py @@ -19,7 +19,6 @@ def test_finally_only_called_once_empty(self): def action(): invasserte_count[0] += 1 - return invasserte_count some_observable = reactivex.empty().pipe(ops.finally_action(action)) @@ -36,7 +35,6 @@ def test_finally_empty(self): def create(): def action(): invasserted[0] = True - return invasserted[0] return xs.pipe(ops.finally_action(action)) @@ -55,7 +53,6 @@ def test_finally_return(self): def create(): def action(): invasserted[0] = True - return invasserted[0] return xs.pipe(ops.finally_action(action)) @@ -78,7 +75,6 @@ def test_finally_on_error(self): def create(): def action(): invasserted[0] = True - return invasserted[0] return xs.pipe(ops.finally_action(action)) diff --git a/tests/test_observable/test_firstordefault.py b/tests/test_observable/test_firstordefault.py index 3f0417a3c..5ed069a29 100644 --- a/tests/test_observable/test_firstordefault.py +++ b/tests/test_observable/test_firstordefault.py @@ -1,4 +1,5 @@ import unittest +from typing import NoReturn from reactivex import operators as ops from reactivex.testing import ReactiveTest, TestScheduler @@ -17,7 +18,7 @@ class RxException(Exception): # Helper function for raising exceptions within lambdas -def _raise(ex): +def _raise(ex: Exception) -> NoReturn: raise RxException(ex) diff --git a/tests/test_observable/test_fromcallback.py b/tests/test_observable/test_fromcallback.py index ca46db720..dc1b95251 100644 --- a/tests/test_observable/test_fromcallback.py +++ b/tests/test_observable/test_fromcallback.py @@ -1,4 +1,5 @@ import unittest +from typing import NoReturn import reactivex from reactivex.testing import ReactiveTest @@ -17,7 +18,7 @@ class RxException(Exception): # Helper function for raising exceptions within lambdas -def _raise(ex): +def _raise(ex: Exception) -> NoReturn: raise RxException(ex) diff --git a/tests/test_observable/test_fromiterable.py b/tests/test_observable/test_fromiterable.py index 93ef96179..456f68fb9 100644 --- a/tests/test_observable/test_fromiterable.py +++ b/tests/test_observable/test_fromiterable.py @@ -1,4 +1,5 @@ import unittest +from typing import NoReturn import reactivex from reactivex.testing import ReactiveTest, TestScheduler @@ -17,7 +18,7 @@ class RxException(Exception): # Helper function for raising exceptions within lambdas -def _raise(ex): +def _raise(ex: Exception) -> NoReturn: raise RxException(ex) @@ -71,4 +72,4 @@ def test_double_subscribe_to_iterable(self): def test_observer_throws(self): with self.assertRaises(RxException): - reactivex.from_iterable([1, 2, 3]).subscribe(lambda x: _raise("ex")) + reactivex.from_iterable([1, 2, 3]).subscribe(lambda x: _raise(Exception("ex"))) diff --git a/tests/test_observable/test_generatewithrelativetime.py b/tests/test_observable/test_generatewithrelativetime.py index 10e7e4bce..50951abdc 100644 --- a/tests/test_observable/test_generatewithrelativetime.py +++ b/tests/test_observable/test_generatewithrelativetime.py @@ -1,4 +1,5 @@ import unittest +from typing import NoReturn import reactivex from reactivex.testing import ReactiveTest, TestScheduler @@ -17,7 +18,7 @@ class RxException(Exception): # Helper function for raising exceptions within lambdas -def _raise(ex): +def _raise(ex: Exception) -> NoReturn: raise RxException(ex) @@ -45,7 +46,7 @@ def test_generate_timespan_throw_condition(self): def create(): return reactivex.generate_with_relative_time( - 0, lambda x: _raise(ex), lambda x: x + 1, lambda x: x + 1 + 0, lambda x: _raise(Exception(ex)), lambda x: x + 1, lambda x: x + 1 ) results = scheduler.start(create) @@ -57,7 +58,7 @@ def test_generate_timespan_throw_iterate(self): def create(): return reactivex.generate_with_relative_time( - 0, lambda x: True, lambda x: _raise(ex), lambda x: x + 1 + 0, lambda x: True, lambda x: _raise(Exception(ex)), lambda x: x + 1 ) results = scheduler.start(create) @@ -69,7 +70,7 @@ def test_generate_timespan_throw_timemapper(self): def create(): return reactivex.generate_with_relative_time( - 0, lambda x: True, lambda x: x + 1, lambda x: _raise(ex) + 0, lambda x: True, lambda x: x + 1, lambda x: _raise(Exception(ex)) ) results = scheduler.start(create) @@ -109,7 +110,7 @@ def test_generate_datetime_offset_throw_condition(self): def create(): return reactivex.generate_with_relative_time( - 0, lambda x: _raise(ex), lambda x: x + 1, lambda x: x + 1 + 0, lambda x: _raise(Exception(ex)), lambda x: x + 1, lambda x: x + 1 ) results = scheduler.start(create) @@ -121,7 +122,7 @@ def test_generate_datetime_offset_throw_iterate(self): def create(): return reactivex.generate_with_relative_time( - 0, lambda x: True, lambda x: _raise(ex), lambda x: x + 1 + 0, lambda x: True, lambda x: _raise(Exception(ex)), lambda x: x + 1 ) results = scheduler.start(create) @@ -133,7 +134,7 @@ def test_generate_datetime_offset_throw_time_mapper(self): def create(): return reactivex.generate_with_relative_time( - 0, lambda x: True, lambda x: x + 1, lambda x: _raise(ex) + 0, lambda x: True, lambda x: x + 1, lambda x: _raise(Exception(ex)) ) results = scheduler.start(create) diff --git a/tests/test_observable/test_last.py b/tests/test_observable/test_last.py index dcf7148a0..a9631a08a 100644 --- a/tests/test_observable/test_last.py +++ b/tests/test_observable/test_last.py @@ -1,4 +1,5 @@ import unittest +from typing import NoReturn from reactivex import operators as _ from reactivex.testing import ReactiveTest, TestScheduler @@ -17,7 +18,7 @@ class RxException(Exception): # Helper function for raising exceptions within lambdas -def _raise(ex): +def _raise(ex: Exception) -> NoReturn: raise RxException(ex) diff --git a/tests/test_observable/test_merge.py b/tests/test_observable/test_merge.py index 0c9ed086a..395f0d7ec 100644 --- a/tests/test_observable/test_merge.py +++ b/tests/test_observable/test_merge.py @@ -291,7 +291,7 @@ def test_merge_error_causes_disposal(self): source_not_disposed = [False] o1 = scheduler.create_hot_observable(msgs1) - def action(): + def action(_: object) -> None: source_not_disposed[0] = True o2 = scheduler.create_hot_observable(msgs2).pipe(ops.do_action(on_next=action)) diff --git a/tests/test_observable/test_minby.py b/tests/test_observable/test_minby.py index 0cc94336e..162c8a2a1 100644 --- a/tests/test_observable/test_minby.py +++ b/tests/test_observable/test_minby.py @@ -1,4 +1,5 @@ import unittest +from typing import NoReturn from reactivex import operators as ops from reactivex.testing import ReactiveTest, TestScheduler @@ -17,7 +18,7 @@ class RxException(Exception): # Helper function for raising exceptions within lambdas -def _raise(ex): +def _raise(ex: Exception) -> NoReturn: raise RxException(ex) @@ -278,7 +279,7 @@ def reverse_comparer(a, b): xs = scheduler.create_hot_observable(msgs) def create(): - return xs.pipe(ops.min_by(lambda x: _raise(ex), reverse_comparer)) + return xs.pipe(ops.min_by(lambda x: _raise(Exception(ex)), reverse_comparer)) res = scheduler.start(create=create).messages assert res == [on_error(210, ex)] @@ -295,7 +296,7 @@ def test_min_by_comparer_throws(self): ] def reverse_comparer(a, b): - _raise(ex) + _raise(Exception(ex)) xs = scheduler.create_hot_observable(msgs) diff --git a/tests/test_observable/test_publish.py b/tests/test_observable/test_publish.py index fba448e86..4f5a17fe3 100644 --- a/tests/test_observable/test_publish.py +++ b/tests/test_observable/test_publish.py @@ -1,4 +1,5 @@ import unittest +from typing import NoReturn import reactivex from reactivex import ConnectableObservable, Observable @@ -20,7 +21,7 @@ class RxException(Exception): # Helper function for raising exceptions within lambdas -def _raise(ex): +def _raise(ex: Exception) -> NoReturn: raise RxException(ex) diff --git a/tests/test_observable/test_returnvalue.py b/tests/test_observable/test_returnvalue.py index 0810342fe..43bf1089e 100644 --- a/tests/test_observable/test_returnvalue.py +++ b/tests/test_observable/test_returnvalue.py @@ -1,4 +1,5 @@ import unittest +from typing import NoReturn import reactivex from reactivex.disposable import SerialDisposable @@ -18,7 +19,7 @@ class RxException(Exception): # Helper function for raising exceptions within lambdas -def _raise(ex): +def _raise(ex: Exception) -> NoReturn: raise RxException(ex) diff --git a/tests/test_observable/test_single.py b/tests/test_observable/test_single.py index 4e93c9683..8bb5c40b2 100644 --- a/tests/test_observable/test_single.py +++ b/tests/test_observable/test_single.py @@ -1,4 +1,5 @@ import unittest +from typing import NoReturn from reactivex import operators as ops from reactivex.testing import ReactiveTest, TestScheduler @@ -17,7 +18,7 @@ class RxException(Exception): # Helper function for raising exceptions within lambdas -def _raise(ex): +def _raise(ex: Exception) -> NoReturn: raise RxException(ex) diff --git a/tests/test_observable/test_singleordefault.py b/tests/test_observable/test_singleordefault.py index 609779242..bf565ac41 100644 --- a/tests/test_observable/test_singleordefault.py +++ b/tests/test_observable/test_singleordefault.py @@ -1,4 +1,5 @@ import unittest +from typing import NoReturn from reactivex import operators as ops from reactivex.testing import ReactiveTest, TestScheduler @@ -17,7 +18,7 @@ class RxException(Exception): # Helper function for raising exceptions within lambdas -def _raise(ex): +def _raise(ex: Exception) -> NoReturn: raise RxException(ex) diff --git a/tests/test_observable/test_takeuntilwithtime.py b/tests/test_observable/test_takeuntilwithtime.py index 6b577a534..95ff7fe6a 100644 --- a/tests/test_observable/test_takeuntilwithtime.py +++ b/tests/test_observable/test_takeuntilwithtime.py @@ -1,4 +1,5 @@ import unittest +from typing import NoReturn from datetime import datetime, timezone from reactivex import operators as ops @@ -18,7 +19,7 @@ class RxException(Exception): # Helper function for raising exceptions within lambdas -def _raise(ex): +def _raise(ex: Exception) -> NoReturn: raise RxException(ex) diff --git a/tests/test_observable/test_timeout.py b/tests/test_observable/test_timeout.py index f78cfc275..93667c54b 100644 --- a/tests/test_observable/test_timeout.py +++ b/tests/test_observable/test_timeout.py @@ -1,4 +1,5 @@ import unittest +from typing import NoReturn from datetime import datetime, timezone from reactivex import operators as ops @@ -18,7 +19,7 @@ class RxException(Exception): # Helper function for raising exceptions within lambdas -def _raise(ex): +def _raise(ex: Exception) -> NoReturn: raise RxException(ex) diff --git a/tests/test_observable/test_timeoutwithmapper.py b/tests/test_observable/test_timeoutwithmapper.py index 6f4454569..43a5540b0 100644 --- a/tests/test_observable/test_timeoutwithmapper.py +++ b/tests/test_observable/test_timeoutwithmapper.py @@ -1,4 +1,5 @@ import unittest +from typing import NoReturn from reactivex import operators as ops from reactivex.testing import ReactiveTest, TestScheduler @@ -17,7 +18,7 @@ class RxException(Exception): # Helper function for raising exceptions within lambdas -def _raise(ex): +def _raise(ex: Exception) -> NoReturn: raise RxException(ex) diff --git a/tests/test_observable/test_using.py b/tests/test_observable/test_using.py index 2158d7256..1f46e93d4 100644 --- a/tests/test_observable/test_using.py +++ b/tests/test_observable/test_using.py @@ -1,4 +1,5 @@ import unittest +from typing import NoReturn import reactivex from reactivex.testing import MockDisposable, ReactiveTest, TestScheduler @@ -17,7 +18,7 @@ class RxException(Exception): # Helper function for raising exceptions within lambdas -def _raise(ex): +def _raise(ex: Exception) -> NoReturn: raise RxException(ex) @@ -165,7 +166,7 @@ def test_using_throw_resource_mapper(self): def create(): def create_resource(): dispose_invoked[0] += 1 - raise _raise(ex) + _raise(Exception(ex)) def create_observable(d): create_invoked[0] += 1 @@ -194,7 +195,7 @@ def create_resource(): def create_observable(d): create_invoked[0] += 1 - _raise(ex) + _raise(Exception(ex)) return reactivex.using(create_resource, create_observable) From 59936b36a11feaa685ab9b2bafc211cb0871d3e6 Mon Sep 17 00:00:00 2001 From: Dag Brattli Date: Fri, 1 May 2026 12:49:27 +0200 Subject: [PATCH 2/3] ci: trigger build From 675b32abca23f0533727125afbcc3f1b35d01e7f Mon Sep 17 00:00:00 2001 From: Dag Brattli Date: Fri, 1 May 2026 13:10:29 +0200 Subject: [PATCH 3/3] style: fix ruff import order and line length in test_observable batch 3 Pre-commit hook failures from PR #785: - Reorder `from typing import NoReturn` after `from datetime` in 3 files - Wrap two long lines exceeding 88 chars in test_fromiterable.py and test_minby.py Co-Authored-By: Claude Opus 4.7 (1M context) --- tests/test_observable/test_delay.py | 2 +- tests/test_observable/test_fromiterable.py | 4 +++- tests/test_observable/test_minby.py | 4 +++- tests/test_observable/test_takeuntilwithtime.py | 2 +- tests/test_observable/test_timeout.py | 2 +- 5 files changed, 9 insertions(+), 5 deletions(-) diff --git a/tests/test_observable/test_delay.py b/tests/test_observable/test_delay.py index a37de53a5..974bba9cb 100644 --- a/tests/test_observable/test_delay.py +++ b/tests/test_observable/test_delay.py @@ -1,7 +1,7 @@ import logging import unittest -from typing import NoReturn from datetime import datetime, timezone +from typing import NoReturn from reactivex.operators import delay from reactivex.testing import ReactiveTest, TestScheduler diff --git a/tests/test_observable/test_fromiterable.py b/tests/test_observable/test_fromiterable.py index 456f68fb9..03c915558 100644 --- a/tests/test_observable/test_fromiterable.py +++ b/tests/test_observable/test_fromiterable.py @@ -72,4 +72,6 @@ def test_double_subscribe_to_iterable(self): def test_observer_throws(self): with self.assertRaises(RxException): - reactivex.from_iterable([1, 2, 3]).subscribe(lambda x: _raise(Exception("ex"))) + reactivex.from_iterable([1, 2, 3]).subscribe( + lambda x: _raise(Exception("ex")) + ) diff --git a/tests/test_observable/test_minby.py b/tests/test_observable/test_minby.py index 162c8a2a1..f8002ec48 100644 --- a/tests/test_observable/test_minby.py +++ b/tests/test_observable/test_minby.py @@ -279,7 +279,9 @@ def reverse_comparer(a, b): xs = scheduler.create_hot_observable(msgs) def create(): - return xs.pipe(ops.min_by(lambda x: _raise(Exception(ex)), reverse_comparer)) + return xs.pipe( + ops.min_by(lambda x: _raise(Exception(ex)), reverse_comparer) + ) res = scheduler.start(create=create).messages assert res == [on_error(210, ex)] diff --git a/tests/test_observable/test_takeuntilwithtime.py b/tests/test_observable/test_takeuntilwithtime.py index 95ff7fe6a..7ad234edd 100644 --- a/tests/test_observable/test_takeuntilwithtime.py +++ b/tests/test_observable/test_takeuntilwithtime.py @@ -1,6 +1,6 @@ import unittest -from typing import NoReturn from datetime import datetime, timezone +from typing import NoReturn from reactivex import operators as ops from reactivex.testing import ReactiveTest, TestScheduler diff --git a/tests/test_observable/test_timeout.py b/tests/test_observable/test_timeout.py index 93667c54b..39b757e61 100644 --- a/tests/test_observable/test_timeout.py +++ b/tests/test_observable/test_timeout.py @@ -1,6 +1,6 @@ import unittest -from typing import NoReturn from datetime import datetime, timezone +from typing import NoReturn from reactivex import operators as ops from reactivex.testing import ReactiveTest, TestScheduler