U
vi8 @ s. d dl Z d dlmZmZmZmZmZ d dlmZm Z m
Z
d dlm Z d dl
mZmZmZmZ d dlmZmZ d dlmZ e dZed Zee eegee f eee geee f d
d d Zee eee geee f d
ddZeg ee f eee geee f dddZ ddd gZ dS ) N)AnyCallableOptionalTupleTypeVar)
Observableabcempty) operators)CompositeDisposableRefCountDisposableSerialDisposableSingleAssignmentDisposable)add_refnoop)SubjectZRx_T)openingsclosing_mapperreturnc s& t t t t t d fdd }|S )Projects each element of an observable sequence into zero or
more windows.
Args:
source: Source observable to project into windows.
Returns:
An observable sequence of windows.
sourcer c s: t ttt f ddd}t| dd t|S )N)argsc S s | \}}|S N )r _windowr r L/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_window.pymapper" s z5window_toggle_..window_toggle..mapperc S s t S r )r )r r r r * z7window_toggle_..window_toggle..)r r r r pipeopsZ
group_joinmap)r r r r r r
window_toggle! s z%window_toggle_..window_toggler r )r r r& r r% r window_toggle_ s
"r( )
boundariesr c s$ t t t t t d fdd }|S )r r c s4 dt jtt tt j t jd fdd
}t|S )N)observer schedulerr c s t t }t| t td dfdd }td d fdd }d d fdd }|j||||d
t t d fd d
}|j||||d
S )N)xr c s | d S r on_next)r, )window_subjectr r on_next_windowJ s zBwindow_..window..subscribe..on_next_window)errr c s | | d S r on_error)r1 r* r/ r r r3 M s
z.window..subscribe..on_errorr c s d S r on_completedr r4 r r r7 Q s z@window_..window..subscribe..on_completedr+ wc s" t t d S r r7 r r. r r9 r* rr/ r r on_next_observer[ s zDwindow_..window..subscribe..on_next_observer)
r r r r. r r Exceptionadd subscriber )r* r+ dr0 r3 r7 r> )r) r r< r rA @ s2 z*window_..window..subscribe)N)r ObserverBaser r r
SchedulerBaseZDisposableBaser rA r) r r r ? s (zwindow_..windowr' )r) r r rF r window_2 s
+rH )r r c s$ t t t t t d fdd }|S )r r c s0 dt jtt tt j d fdd
}t|S )N)r* r+ c s t t}t|t t td dfdd }td dfdd d dfdd }|j ||d
fd d S )
N)valuer c s | d S r r- )rI )r r r r. s zEwindow_when_..window_when..subscribe..on_next)errorr c s | | d S r r2 )rJ r* r r r r3 s
zFwindow_when_..window_when..subscribe..on_errorr5 c s d S r r6 r rK r r r7 s zJwindow_when_..window_when..subscribe..on_completedr8 c
s z
} W n2 t k
r< } z| W Y d S d }~X Y nX fdd}t }|_| tdjt|d|_d S )Nc s( t t d S r r; r )create_window_on_completedr* r= r r r r7 s znwindow_when_..window_when..subscribe..create_window_on_completed..on_completed r8 ) r? r3 r Z
disposabler" r# ZtakerA r )Z window_close exceptionr7 m1)r rL mr* r3 r= r+ r r r rL s
zXwindow_when_..window_when..subscribe..create_window_on_completed)
r
r r r r. r r r? r@ rA )r* r+ rB r. r7 )r r )rL rP r* r3 r= r+ r r rA { s z4window_when_..window_when..subscribe)N)r rC r r r rD rE r rG r window_whenz s 1z!window_when_..window_whenr' )r rR r rQ r window_when_m s
4rS ) loggingtypingr r r r r Z reactivexr r r r
r# Zreactivex.disposabler r r
r Zreactivex.internalr r Zreactivex.subjectr getLoggerlogr r( rH rS __all__r r r r s&
< D