Formatting

Author: dbrattli

reactivex/observable/mixins/combination.py

@@ -347,9 +347,7 @@ def merge_all(self) -> Observable[Any]:
         )
         return self._as_observable().pipe(op)
 
-    def zip_with_iterable(
-        self, second: Iterable[_T2]
-    ) -> Observable[tuple[_T, _T2]]:
+    def zip_with_iterable(self, second: Iterable[_T2]) -> Observable[tuple[_T, _T2]]:
         """Zip with iterable.
 
         Merges the specified observable sequence and iterable into one observable

reactivex/observable/mixins/filtering.py

@@ -702,7 +702,8 @@ def single_or_default_async(
             or the default value if empty.
 
         See Also:
-            - :func:`single_or_default_async <reactivex.operators.single_or_default_async>`
+            - :func:`single_or_default_async \
+<reactivex.operators.single_or_default_async>`
             - :meth:`single_or_default`
             - :meth:`single`
         """
@@ -834,8 +835,8 @@ def last_or_default(
         if predicate is None:
             return self._as_observable().pipe(ops.last_or_default(default_value))
 
-        op: Callable[[Observable[Any]], Observable[Any]] = (
-            ops.last_or_default(default_value, predicate)
+        op: Callable[[Observable[Any]], Observable[Any]] = ops.last_or_default(
+            default_value, predicate
         )
         return self._as_observable().pipe(op)
 

reactivex/observable/mixins/time_based.py

@@ -133,7 +133,9 @@ def throttle_first(
         """
         from reactivex import operators as ops
 
-        return self._as_observable().pipe(ops.throttle_first(window_duration, scheduler))
+        return self._as_observable().pipe(
+            ops.throttle_first(window_duration, scheduler)
+        )
 
     def throttle_with_mapper(
         self,
@@ -150,10 +152,13 @@ def throttle_with_mapper(
 
             Equivalent pipe style:
             >>> from reactivex import operators as ops
-            >>> result = source.pipe(ops.throttle_with_mapper(lambda x: rx.timer(x * 0.1)))
+            >>> result = source.pipe(
+            ...     ops.throttle_with_mapper(lambda x: rx.timer(x * 0.1))
+            ... )
 
         Args:
-            throttle_duration_mapper: Function to compute throttle duration for each item.
+            throttle_duration_mapper: Function to compute throttle duration
+                for each item.
 
         Returns:
             The throttled sequence.
@@ -165,7 +170,9 @@ def throttle_with_mapper(
         """
         from reactivex import operators as ops
 
-        return self._as_observable().pipe(ops.throttle_with_mapper(throttle_duration_mapper))
+        return self._as_observable().pipe(
+            ops.throttle_with_mapper(throttle_duration_mapper)
+        )
 
     def throttle_with_timeout(
         self,