🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 11:35:08 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
operators
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/__pycache__
🔄 Refresh
✏️
Editing: _reduce.cpython-38.pyc
Read Only
U v�i" � @ s� d dl mZmZmZmZmZmZ d dlmZm Z d dlm Z d dl m Z d dlmZ ed�Zed�Ze feeef eeee f eee gee f d�d d �Zd gZd S ) � )�Any�Callable�Type�TypeVar�Union�cast)� Observable�compose)� operators)�NotSet)� Accumulator�_T�_TState)� accumulator�seed�returnc C sT |t k r2tt|�}tj| |d�}t|tj|d��S tt�ttttf | ��t� � �S )a 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 `scan()`. Examples: >>> res = reduce(lambda acc, x: acc + x) >>> res = 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 operator function that takes an observable source and returns an observable sequence containing a single element with the final accumulator value. )r )� default_value) r r r �ops�scanr Zlast_or_defaultr r �last)r r Zseed_�scanner� r �L/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_reduce.py�reduce_ s ��r N)�typingr r r r r r Z reactivexr r r r Zreactivex.internal.utilsr Zreactivex.typingr r r r �__all__r r r r �<module> s � � '
💾 Save Changes
❌ Cancel