U
vi. @ sz d dl mZmZmZ d dlmZmZ d dlmZ d dl m
Z
edZ d
ee
e eee gee f ddd Z
d gZdS ) )CallableOptionalTypeVar)
Observablecompose) operators) Predicate_TN) predicatereturnc C s< | rt t| t S tttddd}tj|dd}|S )N)n_r c S s | d S )N )r r
r r K/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_count.pyreducer s zcount_..reducerr )seed)r opsfiltercountintr reduce)r
r counterr r r count_
s r )N)typingr r r Z reactivexr r r r Zreactivex.typingr r r r __all__r r r r s