U
vâ’iž ã @ s d dl mZmZmZmZmZ d dlmZmZ d dlm Z
edƒZ ee eee geee f dœdd„Z eg ee f eee geee f dœd d
„Z
ee eegee f eee geee f d œd d
„Zdeee eee geee f dœdd„Zddd
d
gZdS )é )ÚAnyÚCallableÚListÚOptionalÚTypeVar)Ú
ObservableÚcompose)Ú operatorsÚ_T)Ú
boundariesÚreturnc C s t t | ¡t t ¡ ¡ƒS ©N)r ÚopsZwindowÚflat_mapÚto_list)r © r úL/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_buffer.pyÚbuffer_ s þr )Úclosing_mapperr c C s t t | ¡t t ¡ ¡ƒS r
)r r Z window_whenr r )r r r r Ú buffer_when_ s þr )Úopeningsr r c C s t t | |¡t t ¡ ¡ƒS r
)r r Z
window_toggler r )r r r r r Úbuffer_toggle_ s
þr N)ÚcountÚskipr c s& t t t tt dœ‡ ‡fdd„ }|S )a9 Projects each element of an observable sequence into zero or more
buffers which are produced based on element count information.
Examples:
>>> res = buffer_with_count(10)(xs)
>>> res = buffer_with_count(10, 1)(xs)
Args:
count: Length of each buffer.
skip: [Optional] Number of elements to skip between
creation of consecutive buffers. If not provided, defaults to
the count.
Returns:
A function that takes an observable source and returns an
observable sequence of buffers.
)Úsourcer c s^ ˆd kr ˆ ‰t t t tt dœdd„}tt tdœdd„}| t ˆ ˆ¡t |¡t |¡¡S )N)Úvaluer c S s | t ¡ ¡S r
)Úpiper r ©r r r r Úmapper? s ÿz=buffer_with_count_..buffer_with_count..mapperc S s t | ƒdkS )Nr )Úlenr r r r Ú predicateD s z@buffer_with_count_..buffer_with_count..predicate) r r
r Úboolr r Zwindow_with_countr Úfilter)r r r ©r r r r Úbuffer_with_count9 s
ýz-buffer_with_count_..buffer_with_count)r r
r )r r r$ r r# r Úbuffer_with_count_$ s "r% )N)Útypingr r r r r Z reactivexr r r r r
r r r Úintr% Ú__all__r r r r Ú s( þ
þ
þ
ÿ þ ,