rx/core/observablebase.py
def reduce(self, accumulator: Accumulator, seed: Any = None) -> 'ObservableBase':
        """The reduce operator.

        Applies an accumulator function over an observable sequence,
        returning the result of the aggregation as a single element in
        the result sequence. The specified seed value is used as the
        initial accumulator value.

        For aggregation behavior with incremental intermediate results,
        see Observable.scan.

        Examples:
            >>> res = source.reduce(lambda acc, x: acc + x)
            >>> res = source.reduce(lambda acc, x: acc + x, 0)

        Args:
            accumulator: An accumulator function to be invoked on each element.
            seed: Optional initial accumulator value.

        Returns:
            An observable sequence containing a single element with the
            final accumulator value.
        """
        from ..operators.observable.reduce import reduce
        return reduce(self, accumulator, seed)
The reduce operator.

        Applies an accumulator function over an observable sequence,
        returning the result of the aggregation as a single element in
        the result sequence. The specified seed value is used as the
        initial accumulator value.

        For aggregation behavior with incremental intermediate results,
        see Observable.scan.

        Examples:
            >>> res = source.reduce(lambda acc, x: acc + x)
            >>> res = source.reduce(lambda acc, x: acc + x, 0)

        Args:
            accumulator: An accumulator function to be invoked on each element.
            seed: Optional initial accumulator value.

        Returns:
            An observable sequence containing a single element with the
            final accumulator value.
        
The reduce operator.
Applies an accumulator function over an observable sequence,
returning the result of the aggregation as a single element in
the result sequence. The specified seed value is used as the
initial accumulator value.

For aggregation behavior with incremental intermediate results,
see Observable.scan.
The reduce operator . Applies an accumulator function over an observable sequence returning the result of the aggregation as a single element in the result sequence . The specified seed value is used as the initial accumulator value . For aggregation behavior with incremental intermediate results see Observable . scan .
def reduce(self, accumulator: Accumulator, seed: Any = None) -> 'ObservableBase':
        from ..operators.observable.reduce import reduce
        return reduce(self, accumulator, seed)
def reduce ( self , accumulator : Accumulator , seed : Any = None ) -> 'ObservableBase' : from . . operators . observable . reduce import reduce return reduce ( self , accumulator , seed )
The reduce operator.
The reduce operator .
"""The reduce operator.

        Applies an accumulator function over an observable sequence,
        returning the result of the aggregation as a single element in
        the result sequence. The specified seed value is used as the
        initial accumulator value.

        For aggregation behavior with incremental intermediate results,
        see Observable.scan.

        Examples:
            >>> res = source.reduce(lambda acc, x: acc + x)
            >>> res = source.reduce(lambda acc, x: acc + x, 0)

        Args:
            accumulator: An accumulator function to be invoked on each element.
            seed: Optional initial accumulator value.

        Returns:
            An observable sequence containing a single element with the
            final accumulator value.
        """
An observable sequence containing a single element with the
final accumulator value.
An observable sequence containing a single element with the final accumulator value .
self
accumulator
Accumulator
An accumulator function to be invoked on each element.
An accumulator function to be invoked on each element .
seed
Any
Optional initial accumulator value.
Optional initial accumulator value .
examples
>>> res = source.reduce(lambda acc, x: acc + x)
>>> res = source.reduce(lambda acc, x: acc + x, 0)
>>> res = source . reduce ( lambda acc x : acc + x ) >>> res = source . reduce ( lambda acc x : acc + x 0 )