U
vi
@ s d dl Z d dlmZmZmZmZ d dlmZmZ d dl m
Z
m Z d dl m
Z
mZ d dlmZ e dZedZd eee eee geee f d d
d Zd gZdS )
N)CallableListOptionalTypeVar)
Observableabc)RefCountDisposableSingleAssignmentDisposable)ArgumentOutOfRangeExceptionadd_ref)SubjectZRx_T)countskipreturnc sR dkrt |dk r|n dkr,t tt ttt d fdd }|S )a Projects each element of an observable sequence into zero or more
windows which are produced based on element count information.
Examples:
>>> window_with_count(10)
>>> window_with_count(10, 1)
Args:
count: Length of each window.
skip: [Optional] Number of elements to skip between creation of
consecutive windows. If not specified, defaults to the
count.
Returns:
An observable sequence of windows.
r N)sourcer c s2 dt jtt tt j d fdd
}t|S )N)observer schedulerc s t }t|dgg fdd td d fdd }td dfdd }d d
fd d }j||||d
|_S )Nr c s$ t } | t| d S )N)r appendon_nextr )s)r qrefCountDisposable U/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_windowwithcount.py
create_window4 s
zWwindow_with_count_..window_with_count..subscribe..create_window)xr c st D ]}| | qd d }|dkrJ| dkrJd}| d d7 < d dkrp d S )Nr )r pop on_completed)r itemcr )r r nr skip_r r r ; s
zQwindow_with_count_..window_with_count..subscribe..on_next) exceptionr c s$ r d| q | d S Nr )r on_error)r$ r r r r r& H s zRwindow_with_count_..window_with_count..subscribe..on_error)r c s r d q d S r% )r r r r' r r r M s zVwindow_with_count_..window_with_count..subscribe..on_completed)r )r r r
Exception subscribeZ
disposable)r r mr r& r )r r# r )r r" r r r r r) + s
z@window_with_count_..window_with_count..subscribe)N)r Z ObserverBaser r
r Z
SchedulerBase)r r) r r# )r r window_with_count* s ,z-window_with_count_..window_with_count)r
r r
)r r r, r r+ r window_with_count_ s "/r- )N)loggingtypingr r r r Z reactivexr r Zreactivex.disposabler r Zreactivex.internalr
r Zreactivex.subjectr getLoggerlogr
intr- __all__r r r r s
N