U
viQ @ s d dl mZmZmZmZ d dlmZmZmZ d dlm Z
d dlm Z d dl m Z d dl
mZ d dlmZmZ edZed Zdeeeef eee gee f d d d
Zdeeeef eee gee f dddZd
dgZd
S ) )CallableOptionalTypeVarcast)
Observableabccompose) operators)typing)identity)infinite)Mapper
MapperIndexed_T1_T2N)mapperreturnc s6 | pt tttf t tt tt d fdd }|S )N)sourcer c s0 dt jt tt j t jd fdd
}t|S )a Partially applied map operator.
Project each element of an observable sequence into a new form
by incorporating the element's index.
Example:
>>> map(source)
Args:
source: The observable source to transform.
Returns:
Returns an observable sequence whose elements are the
result of invoking the transform function on each element
of the source.
N)obv schedulerr c s, t d d fdd }j| j j|dS )N)valuer c
sH z | }W n, t k
r8 } z| W 5 d }~X Y n X | d S N) Exceptionon_erroron_next)r resulterr)_mapperr I/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_map.pyr ( s
z5map_..map..subscribe..on_next)r )r subscriber Z on_completed)r r r )r r )r r r % s z$map_..map..subscribe)N)r Z ObserverBaser r Z
SchedulerBaseZDisposableBaser )r r r )r r map s zmap_..map)r r
r r r r )r r" r r! r map_ s #r# )mapper_indexedr c C sB t ttddd}| p(ttjt tf |}ttt t
|S )N)r _r c S s
t t| S r )r r )r r% r r r _identity< s z map_indexed_.._identity) r intr r r
r r opsZzip_with_iterabler Zstarmap_indexed)r$ r& Z_mapper_indexedr r r map_indexed_9 s
r) )N)N)r
r r r r Z reactivexr r r r r( Zreactivex.internal.basicr Zreactivex.internal.utilsr Zreactivex.typingr
r r r r# r) __all__r r r r s& ,