U
vi4 @ sd d dl mZmZmZ d dlmZmZ d dlmZ edZ e
eee gee f dddZ dgZ dS ) )CallableOptionalTypeVar)
Observableabc)ArgumentOutOfRangeException_T)countreturnc s. dk rt tt tt d fdd }|S )Nr )sourcer
c s, dt jt tt j d fdd
}t|S )ai The skip operator.
Bypasses a specified number of elements in an observable sequence
and then returns the remaining elements.
Args:
source: The source observable.
Returns:
An observable sequence that contains the elements that occur
after the specified index in the input sequence.
N)observer schedulerc s0 t d d fdd }j| j j|dS )N)valuer
c s dkr | nd8 d S )Nr )on_next)r r remaining J/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_skip.pyr ! s z7skip_..skip..subscribe..on_next)r
)r subscribeZon_errorZ on_completed)r r
r )r r r r r s z&skip_..skip..subscribe)N)r Z ObserverBaser r Z
SchedulerBaser )r r r )r r skip
s zskip_..skip)r r r )r r r r r skip_ s "r N)
typingr r r Z reactivexr r Zreactivex.internalr r intr __all__r r r r s
")