diff --git a/reactivex/operators/__init__.py b/reactivex/operators/__init__.py index cbf9b551..4c70b3d3 100644 --- a/reactivex/operators/__init__.py +++ b/reactivex/operators/__init__.py @@ -3228,16 +3228,16 @@ def starmap_indexed( invoking the indexed mapper function with unpacked elements of the source. """ - from ._map import map_ + from ._map import map_indexed_ if mapper is None: return compose(identity) - def starred(values: Tuple[Any, ...]) -> Any: + def starred(values: Tuple[Any, ...], i: int) -> Any: assert mapper # mypy is paranoid - return mapper(*values) + return mapper(*values, i) - return compose(map_(starred)) + return compose(map_indexed_(starred)) def start_with(*args: _T) -> Callable[[Observable[_T]], Observable[_T]]: diff --git a/reactivex/operators/_map.py b/reactivex/operators/_map.py index 48b4c094..25009cd7 100644 --- a/reactivex/operators/_map.py +++ b/reactivex/operators/_map.py @@ -65,7 +65,7 @@ def _identity(value: _T1, _: int) -> _T2: return compose( ops.zip_with_iterable(infinite()), - ops.starmap_indexed(_mapper_indexed), + ops.starmap(_mapper_indexed), )