U
vik @ s d dl mZmZmZmZ d dlmZmZmZ d dlm Z
d dlm Z edZ d
e j ee j eej
eee geee f ddd Zd gZdS ) )CallableListOptionalTypeVar)
Observableabccompose) operators)typing_TN)timespan timeshift schedulerreturnc C s& |s| }t t| ||tt S )N)r opsZwindow_with_timeZflat_mapZto_list)r r
r r T/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_bufferwithtime.pybuffer_with_time_
s r )NN)r
r r r r Z reactivexr r r r r r Z RelativeTimeZ
SchedulerBaser __all__r r r r s