Minor adjustments

docs/migration.rst

@@ -3,13 +3,18 @@
 Migration v4
 ============
 
-ReactiveX for Python v4 is yet annother major evolution of RxPY v3:
-
-- Project main module renamed from `rx` to `reactivex`.
-- Type annotation. Code now type checks with pyright / pylance at strict
-  settings
-- RxPY is now a modern Python project using Poetry, Black formatter and
-  isort.
+ReactiveX for Python v4 is yet another evolution of RxPY v3:
+
+- Project main module renamed from ``rx`` to ``reactivex``. This is done
+  to give it a unique name different from the obsolete `Reactive Extensions
+  (RxPY) <https://github.com/Reactive-Extensions/RxPy>`_
+- Generic type annotations. Code now type checks with pyright / pylance
+  at strict settings. It also for most type checks with mypy. Mypy
+  should eventually catch up.
+- The ``pipe`` function has been renamed to ``compose``. There is now a
+  new function ``pipe`` that works similar to the ``pipe`` method.
+- RxPY is now a modern Python project using ``pyproject.toml``, Poetry,
+  Black formatter and isort.
 
 .. code:: python
 

pyproject.toml

@@ -1,7 +1,7 @@
 [tool.poetry]
 name = "reactivex"
 version = "4.0.0a4"  # Make sure the version here is the same as in _version.py
-description = "Reactive Extensions (Rx) for Python"
+description = "ReactiveX (Rx) for Python"
 readme = "README.rst"
 authors = ["Dag Brattli <[email protected]>"]
 license = "MIT License"
@@ -59,7 +59,7 @@ float_to_top=true
 python_version = "3.9"
 follow_imports = "silent"
 files = ["reactivex"]
-exclude = ["reactivex/operators/_\\w.*\\.py$"]
+exclude = ["reactivex/operators/_\\w.*\\.py$"] # mypy will eventually catch up
 
 [tool.pytest.ini_options]
 testpaths = ["tests"]

reactivex/operators/_zip.py

@@ -7,11 +7,10 @@
 _TOther = TypeVar("_TOther")
 
 
-# pylint: disable=redefined-builtin
 def zip_(
     *args: Observable[Any],
 ) -> Callable[[Observable[Any]], Observable[Tuple[Any, ...]]]:
-    def zip(source: Observable[Any]) -> Observable[Tuple[Any, ...]]:
+    def _zip(source: Observable[Any]) -> Observable[Tuple[Any, ...]]:
         """Merges the specified observable sequences into one observable
         sequence by creating a tuple whenever all of the
         observable sequences have produced an element at a corresponding
@@ -29,7 +28,7 @@ def zip(source: Observable[Any]) -> Observable[Tuple[Any, ...]]:
         """
         return reactivex.zip(source, *args)
 
-    return zip
+    return _zip
 
 
 def zip_with_iterable_(