U
vi @ s d dl mZ d dlmZmZmZmZmZ d dlm Z m
Z
mZ edZ eG dd dZ d eej
e ef ee e ge e f dd d
Zd
gZdS ) ) dataclass)AnyCallableOptionalTypeVarcast)
Observable operatorstyping_Tc @ s e Zd ZU eed< eed< dS ) AverageValuesumcountN)__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_mapperreturnc s t t t t d fdd }|S )N)sourcer c sf p
dd }t tt ddd}t tddd}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 % z+average_..average..)prevcurr c S s t | j| | jd dS )N r
r )r r
r )r r r r r accumulator( s z.average_..average..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_..average..mapperr r )r r piper mapscanlast)r Z key_mapper_r! r$ seedretr r r average s
zaverage_..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 s /