U
vâ’i- ã @ sŠ d dl mZmZmZmZ d dlmZmZmZ d dlm Z
d dlm Z edƒZ d
e j e
eej eee geee f dœdd „Zd gZdS ) é )ÚCallableÚListÚOptionalÚTypeVar)Ú
ObservableÚabcÚcompose)Ú operators)ÚtypingÚ_TN)ÚtimespanÚcountÚ schedulerÚreturnc C s t t | ||¡t t ¡ ¡ƒS )N)r ÚopsZwindow_with_time_or_countZflat_mapZ to_iterable)r r
r © r ú[/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_bufferwithtimeorcount.pyÚbuffer_with_time_or_count_
s þr )N)r
r r r r Z reactivexr r r r r r Z RelativeTimeÚintZ
SchedulerBaser Ú__all__r r r r Ú s ýü