U
vi @ sh d dl mZmZmZ d dlmZmZmZ d dlm Z edZ
e eee
gee
f dddZ dgZ
dS ) )CallableOptionalTypeVar)
Observableabcempty)ArgumentOutOfRangeException_T)countreturnc s. dk rt tt tt d fdd }|S )Nr )sourcer c s6 s
t S dtjt ttj d fdd
}t|S )aZ Returns a specified number of contiguous elements from the start of
an observable sequence.
>>> take(source)
Keyword arguments:
count -- The number of elements to return.
Returns an observable sequence that contains the specified number of
elements from the start of the input sequence.
N)observer schedulerc s0 t d d fdd }j| j j|dS )N)valuer c s* dkr&d8 | s& d S )Nr )on_next on_completed)r r
remaining J/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_take.pyr # s
z7take_..take..subscribe..on_next)r )r subscribeZon_errorr )r
r r )r
r r r r s z&take_..take..subscribe)N)r r Z ObserverBaser r Z
SchedulerBaser )r r r
)r r take
s
ztake_..take)r r r )r
r r r r take_ s %r N)typingr r r Z reactivexr r r Zreactivex.internalr r intr __all__r r r r s
",