19256769043

Committed 11 Nov 2025 06:09AM UTC coverage: 93.425% (-0.04%) from 93.462%

Build # 19256769043

Build Type

push

github

Committed by

web-flow

Commit Message

RxPY v5 (#743)

* Add back fluent method chaining

* Add windowing operators

* Add more tests

* Formatting

* Update deps

* Update docs

* Curry flip

* Use curry-flipping operators

* Better generic types

* Format test files with ruff

Apply ruff formatting to all test files as Stage 0 of the test linting
enablement plan. This separates formatting changes from type annotation
work for cleaner diffs and easier review.

Changes:
- 19 files reformatted (mainly removing unnecessary line breaks)
- 167 files already formatted (no changes)
- All tests still pass

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>

* Update ruff configuration for staged test linting

Replace blanket "tests" exclusion with specific directory exclusions
matching the pyright configuration. This aligns both tools and makes
the staged rollout plan clearer.

Changes:
- Remove generic "tests" from ruff exclude list
- Add specific test directories to exclude
- Both ruff and pyright now have identical test exclusions
- Will remove exclusions incrementally as each stage completes

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>

Run Details

3390 of 3626 new or added lines in 119 files covered. (93.49%)

13 existing lines in 3 files now uncovered.

25007 of 26767 relevant lines covered (93.42%)

0.93 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

88.89

/reactivex/internal/basic.py

from datetime import datetime, timezone
from typing import Any, NoReturn, TypeVar

_T = TypeVar("_T")


def noop(*args: Any, **kw: Any) -> None:
    """No operation. Returns nothing"""


def identity(x: _T) -> _T:
    """Returns argument x"""
    return x


def default_now() -> datetime:
    return datetime.now(timezone.utc)


def default_comparer(x: _T, y: _T) -> bool:
    return x == y


def default_sub_comparer(x: Any, y: Any) -> Any:
    return x - y


def default_key_serializer(x: Any) -> str:
    return str(x)


def default_error(err: Exception | str) -> NoReturn:
    if isinstance(err, BaseException):
        raise err

    raise Exception(err)

1	from datetime import datetime, timezone	1✔
2	from typing import Any, NoReturn, TypeVar	1✔
3
4	_T = TypeVar("_T")	1✔
5
6
7	def noop(args: Any, *kw: Any) -> None:	1✔
8	"""No operation. Returns nothing"""
9
10
11	def identity(x: _T) -> _T:	1✔
12	"""Returns argument x"""
13	return x	1✔
14
15
16	def default_now() -> datetime:	1✔
17	return datetime.now(timezone.utc)	1✔
18
19
20	def default_comparer(x: _T, y: _T) -> bool:	1✔
21	return x == y	1✔
22
23
24	def default_sub_comparer(x: Any, y: Any) -> Any:	1✔
25	return x - y	1✔
26
27
28	def default_key_serializer(x: Any) -> str:	1✔
29	return str(x)	×
30
31
32	def default_error(err: Exception \| str) -> NoReturn:	1✔
33	if isinstance(err, BaseException):	1✔
34	raise err	1✔
35
UNCOV 36	raise Exception(err)	×

ReactiveX / RxPY / 19256769043

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous