U
vi @ s d dl mZmZmZmZmZ d dlmZmZ d dl m
Z
edZ edZ edZ
d e
e e f ee
e e
f eee geee e
f f dd d
Zd
gZdS ) )CallableDictOptionalTypeVarcast)
Observableabc)Mapper_T_TKey_TValueN)
key_mapperelement_mapperreturnc s* t t t tttf d fdd }|S )N)sourcer c s: dt jtttf tt j t jd fdd
}t|S )a Converts the observable sequence to a Map if it exists.
Args:
source: Source observable to convert.
Returns:
An observable sequence with a single value of a dictionary
containing the values from the observable sequence.
N)observer schedulerr c sH t td d fdd }d d fdd }j|j||dS )N)xr c
s z | }W n2 t k
r> } z| W Y d S d }~X Y nX rz | }W q t k
r } z| W Y d S d }~X Y qX n
tt| }||< d S N) Exceptionon_errorr r )r keyexelement)r r
mr L/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_todict.pyon_next s
z=to_dict_..to_dict..subscribe..on_next)r c s t d S r )r dict on_completedr r r r r r 1 s
zBto_dict_..to_dict..subscribe..on_completed)r )r r
subscriber )r r r r )r r
r r r r! s z,to_dict_..to_dict..subscribe)N) r Z ObserverBaser r r r Z
SchedulerBaseZDisposableBaser )r r! r r
)r r to_dict s
"zto_dict_..to_dict)r r
r r r )r
r r# r r" r to_dict_ s &/r$ )N)typingr r r r r Z reactivexr r Zreactivex.typingr r
r r r$ __all__r r r r s
5