Fix starmap_indexed not passing index

ReactiveX · Nov 13, 2024 · 10c43c2 · 10c43c2
1 parent acfba97
commit 10c43c2
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git 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
@@ -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),
     )