diff --git a/reactivex/operators/__init__.py b/reactivex/operators/__init__.py index ca386880..cbf9b551 100644 --- a/reactivex/operators/__init__.py +++ b/reactivex/operators/__init__.py @@ -3889,7 +3889,7 @@ def to_iterable() -> Callable[[Observable[_T]], Observable[List[_T]]]: There is also an alias called ``to_list``. Returns: - An operator function that takes an obserable source and + An operator function that takes an observable source and returns an observable sequence containing a single element with an iterable containing all the elements of the source sequence. """ diff --git a/reactivex/operators/_partition.py b/reactivex/operators/_partition.py index 2f005e7d..26b03296 100644 --- a/reactivex/operators/_partition.py +++ b/reactivex/operators/_partition.py @@ -23,7 +23,7 @@ def partition(source: Observable[_T]) -> List[Observable[_T]]: when the source completes. Args: - source: Source obserable to partition. + source: Source observable to partition. Returns: A list of observables. The first triggers when the diff --git a/reactivex/operators/_sequenceequal.py b/reactivex/operators/_sequenceequal.py index d79a531b..a3019d6a 100644 --- a/reactivex/operators/_sequenceequal.py +++ b/reactivex/operators/_sequenceequal.py @@ -31,7 +31,7 @@ def sequence_equal(source: Observable[_T]) -> Observable[bool]: ) Args: - source: Source obserable to compare. + source: Source observable to compare. Returns: An observable sequence that contains a single element which diff --git a/reactivex/operators/_timeout.py b/reactivex/operators/_timeout.py index 2e2d6e19..585f0b7b 100644 --- a/reactivex/operators/_timeout.py +++ b/reactivex/operators/_timeout.py @@ -36,7 +36,7 @@ def timeout(source: Observable[_T]) -> Observable[_T]: source: Source observable to timeout Returns: - An obserable sequence switching to the other sequence in + An observable sequence switching to the other sequence in case of a timeout. """