U
vi8 @ s d dl mZmZmZmZ d dlZd dlmZmZ d dlm Z m
Z
m Z edZ d eee eeegee f eee eee gee f dddZ
dgZdS )
)AnyCallableOptionalTypeVarN)
Observableabc)CompositeDisposableSerialDisposableSingleAssignmentDisposable_T)
first_timeouttimeout_duration_mapperotherreturnc sB | p
t |p t tdtt tt d fdd }|S )a Returns the source observable sequence, switching to the other
observable sequence if a timeout is signaled.
res = timeout_with_mapper(reactivex.timer(500))
res = timeout_with_mapper(reactivex.timer(500), lambda x: reactivex.timer(200))
res = timeout_with_mapper(
reactivex.timer(500),
lambda x: reactivex.timer(200)),
reactivex.return_value(42)
)
Args:
first_timeout -- [Optional] Observable sequence that represents the
timeout for the first element. If not provided, this defaults to
reactivex.never().
timeout_duration_mapper -- [Optional] Selector to retrieve an
observable sequence that represents the timeout between the
current element and the next element.
other -- [Optional] Sequence to return in case of a timeout. If not
provided, this is set to reactivex.throw().
Returns:
The source sequence switching to the other sequence in case
of a timeout.
Timeout)sourcer c s4 dt jt tt j t jd fdd
}t|S )N)observer schedulerr c s t t t }|_ddg tt d d fdd fddtd d fd d
}td d fd d
}d dfdd }
j|||d|_tS )NFr )timeoutr c s d fddt _td d fdd }td dfdd }d d
fd d }| j|||d
_d S )Nr c s d kS )Nr r )_idmy_idr W/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_timeoutwithmapper.py
timer_winsA s zktimeout_with_mapper_..timeout_with_mapper..subscribe..set_timer..timer_winsxr c s" rj d_ d S )Nr ) subscribe
disposableZdispose)r )dr other_r subscriptionr r r on_nextG s zhtimeout_with_mapper_..timeout_with_mapper..subscribe..set_timer..on_next)er c s r | d S Non_error)r# )r r r r r& O s zitimeout_with_mapper_..timeout_with_mapper..subscribe..set_timer..on_errorr c s r _d S r$ )r r r )r r r! r r r on_completedS s zmtimeout_with_mapper_..timeout_with_mapper..subscribe..set_timer..on_completedr )r
r r Exceptionr )r r" r& r( )r r r r r! timer)r r r r set_timer> s zWtimeout_with_mapper_..timeout_with_mapper..subscribe..set_timerc s } | r d d7 < | S )Nr r )res)r switchedr r
observer_wins] s z[timeout_with_mapper_..timeout_with_mapper..subscribe..observer_winsr c
sl rh | d }zr"| nt }W n2 tk
r^ } z | W Y d S d }~X Y nX | d S r$ )r" reactivexneverr) r& )r r r# )r r/ r+ r
r r r" d s
zUtimeout_with_mapper_..timeout_with_mapper..subscribe..on_next)errorr c s r | d S r$ r% )r2 r r/ r r r& t s zVtimeout_with_mapper_..timeout_with_mapper..subscribe..on_errorr' c s r d S r$ )r( r r3 r r r( x s zZtimeout_with_mapper_..timeout_with_mapper..subscribe..on_completedr ) r r
r r r r r) r r )r r originalr" r& r( )first_timeout_r r r
)r r r/ r r+ r! r. r* r r 1 s& " zDtimeout_with_mapper_..timeout_with_mapper..subscribe)N)r Z ObserverBaser r Z
SchedulerBaseZDisposableBaser )r r r5 r r
)r r timeout_with_mapper0 s Pz1timeout_with_mapper_..timeout_with_mapper)r0 r1 throwr) r r )r r
r r7 r r6 r timeout_with_mapper_ s Sr9 )NNN)typingr r r r r0 r r Zreactivex.disposabler r r
r r9 __all__r r r r s
x