U
vi @ s d dl mZ d dlmZ d dlmZmZmZmZmZ d dl m
Z
m Z m Z m
Z
mZ d dlmZmZmZ d dlmZ edZd
ejeee
e d f ee j ee
e ge
e f d
d d ZdS ) )Future)datetime)AnyCallableOptionalTypeVarUnion)
Observableabc from_futurethrowtyping)CompositeDisposableSerialDisposableSingleAssignmentDisposable)TimeoutScheduler_TNz
Future[_T])duetimeother schedulerreturnc sL |pt td}t|tr$t|n|tt tt d fdd }|S )NTimeout)sourcer c s4 dt jt tt j t jd fdd
}t|S )a\ Returns the source observable sequence or the other observable
sequence if duetime elapses.
Examples:
>>> res = timeout(source)
Args:
source: Source observable to timeout
Returns:
An observable sequence switching to the other sequence in
case of a timeout.
N)observer
scheduler_r c s p|pt dgdg t }t t |_d d fdd td d fdd }td d fd
d }d d fd d
}
j||||d|_tS )NFr )r c sV d dt jtd fdd
} ttrD| _n| _d S )Nr )r statec s0 d kd< d }|r,j | d_d S )Nr r ) subscribe
disposable)r r Z
timer_wins)_idmy_idobsr subscriptionswitched M/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_timeout.pyaction< s zRtimeout_..timeout..subscribe..create_timer..action)N)r
SchedulerBaser
isinstancer Zschedule_absoluter Zschedule_relative)r& )r
_schedulerr r! r r" r# timer)r r% create_timer9 s
"
zBtimeout_..timeout..subscribe..create_timer)valuer c s2 d }|r. d d7 < | d S Nr )on_next)r, Z send_wins)r r+ r r# r$ r% r/ K s
z=timeout_..timeout..subscribe..on_next)errorr c s, d }|r( d d7 < | d S r- )on_error)r0 Z
on_error_winsr r r# r$ r% r1 R s
z>timeout_..timeout..subscribe..on_errorc s* d } | r& d d7 < d S r- ) on_completed)Zon_completed_winsr2 r$ r% r3 X s
zBtimeout_..timeout..subscribe..on_completedr ) r Z singletonr r r r Exceptionr r )r r originalr/ r1 r3 )r r! r r )r r) r+ r r" r# r* r% r + s& z,timeout_..timeout..subscribe)N)r
Z ObserverBaser r r' ZDisposableBaser )r r r r! r )r r% timeout s 8ztimeout_..timeout)r r4 r( r r r r )r r r r7 r$ r6 r% timeout_ s
Ir8 )NN)asyncior r r
r r r r r Z reactivexr r
r r Zreactivex.disposabler r r Zreactivex.schedulerr r ZAbsoluteOrRelativeTimer' r8 r$ r$ r$ r% s