U
vi) @ s d dl mZmZmZmZ d dlmZmZm Z d dlm Z m
Z
m Z m Z d dl
mZ d dlmZ d dlmZ edZd e jeeej eee geee f d d
d Zd gZdS )
)AnyCallableOptionalTypeVar)
Observableabctyping)CompositeDisposableRefCountDisposableSerialDisposableSingleAssignmentDisposable)add_ref)TimeoutScheduler)Subject_TN)timespancount schedulerreturnc s( t t t t t d fdd }|S )N)sourcer c s8 dt jtt tt j t jd fdd
}t|S )N)observer
scheduler_r c
s p|pt dt t dt}t|td f dd t d t d dfdd }t
d dfd d
}d d fd d
}|
j ||||d S )Nr _idc sB t }|_dtjtd fdd
}||_d S )N)r statec sF kr d S dd7 } t t | d S )Nr ) on_completedr on_nextr
)r r new_id)r create_timernr ref_count_disposables window_id [/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_windowwithtimeorcount.pyaction) s zvwindow_with_time_or_count_..window_with_time_or_count..subscribe..create_timer..action)N)r Z
disposabler
SchedulerBaser Zschedule_relative)r mr& )
_schedulerr r r r! r" timer_dr r# r r% r $ s $
zfwindow_with_time_or_count_..window_with_time_or_count..subscribe..create_timer)xr c sd d}d} | d7 krTd}dd7 } t t |r`| d S )NFr r T)r r r r
)r+ Z
new_windowr )r r r r r! r" r# r$ r% r ; s
zawindow_with_time_or_count_..window_with_time_or_count..subscribe..on_next)er c s | | d S N)on_error)r, r r" r$ r% r. N s
zbwindow_with_time_or_count_..window_with_time_or_count..subscribe..on_error)r c s d S r- )r r$ r/ r$ r% r R s zfwindow_with_time_or_count_..window_with_time_or_count..subscribe..on_completed)r )
r Z singletonr r r r
intr r
r Exceptionadd subscribe)r r Zgroup_disposabler r. r )r r r r )r) r r r r! r" r* r# r% r3 s" " zPwindow_with_time_or_count_..window_with_time_or_count..subscribe)N)r Z ObserverBaser r r r' ZDisposableBase)r r3 r r r )r r% window_with_time_or_count s Dz=window_with_time_or_count_..window_with_time_or_count)r r )r r r r5 r$ r4 r% window_with_time_or_count_ s $Gr6 )N)r r r r r Z reactivexr r Zreactivex.disposabler r
r r Zreactivex.internalr
Zreactivex.schedulerr Zreactivex.subjectr r Z RelativeTimer0 r' r6 __all__r$ r$ r$ r% s O