From 8263b1e36231aeec956e825a991f3350ee3e74a7 Mon Sep 17 00:00:00 2001 From: mat Date: Fri, 23 Dec 2022 04:50:09 +0800 Subject: [PATCH] Observable spelling --- reactivex/operators/__init__.py | 2 +- reactivex/operators/_partition.py | 2 +- reactivex/operators/_sequenceequal.py | 2 +- reactivex/operators/_timeout.py | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/reactivex/operators/__init__.py b/reactivex/operators/__init__.py index ca3868801..cbf9b551f 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 2f005e7db..26b032966 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 d79a531b8..a3019d6a7 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 2e2d6e196..585f0b7b5 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. """