🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 12:38:23 | 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: _average.cpython-38.pyc
Read Only
U v�i� � @ s� d dl mZ d dlmZmZmZmZmZ d dlm Z m Z mZ ed�Z eG dd� d��Z d eej e ef ee e ge e f d�d d �Zd gZdS ) � )� dataclass)�Any�Callable�Optional�TypeVar�cast)� Observable� operators�typing�_Tc @ s e Zd ZU eed< eed< dS )� AverageValue�sum�countN)�__name__� __module__� __qualname__�float�__annotations__�int� r r �M/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_average.pyr s r N)� key_mapper�returnc s t t t t d�� fdd� }|S )N)�sourcer c sf � p dd� }t tt d�dd�}t td�dd�}t d d d �}| �t�|�t�||�t�� t�|��}|S ) a� Partially applied average operator. Computes the average of an observable sequence of values that are in the sequence or obtained by invoking a transform function on each element of the input sequence if present. Examples: >>> res = average(source) Args: source: Source observable to average. Returns: An observable sequence containing a single element with the average of the sequence of values. c S s t tt| ��S )N)r r r )�xr r r �<lambda>% � z+average_.<locals>.average.<locals>.<lambda>)�prev�curr c S s t | j| | jd d�S )N� �r r )r r r )r r r r r � accumulator( s z.average_.<locals>.average.<locals>.accumulator)�sr c S s" | j dkrtd��| jt| j � S )Nr z The input sequence was empty)r � Exceptionr r )r" r r r �mapper+ s z)average_.<locals>.average.<locals>.mapperr r )r r �piper �map�scan�last)r Z key_mapper_r! r$ �seed�ret�r r r �average s � �zaverage_.<locals>.average)r r r )r r, r r+ r �average_ s )r- )N)� dataclassesr r r r r r r Z reactivexr r r r ZMapperr r- �__all__r r r r �<module> s �� /
💾 Save Changes
❌ Cancel