U
vi6 @ s\ d dl mZmZmZmZ d dlmZmZ edZe eee gee f dddZ
dgZ dS ) )CallableListOptionalTypeVar)
Observableabc_T)countreturnc s t t t t d fdd }|S )N)sourcer
c s, dt jt tt j d fdd
}t|S )ar Bypasses a specified number of elements at the end of an
observable sequence.
This operator accumulates a queue with a length enough to store
the first `count` elements. As more elements are received,
elements are taken from the front of the queue and produced on
the result sequence. This causes elements to be delayed.
Args:
count: Number of elements to bypass at the end of the
source sequence.
Returns:
An observable sequence containing the source sequence
elements except for the bypassed ones at the end.
N)observer schedulerc s4 g t d d fdd }j| j j|dS )N)valuer
c sL d }j & | t kr,d}W 5 Q R X |d k rH| d S )Nr )lockappendlenpopon_next)r Zfront)r r qr N/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_skiplast.pyr ! s
zAskip_last_..skip_last..subscribe..on_next)r
)r subscribeZon_errorZ on_completed)r r
r )r r )r r r r s
z0skip_last_..skip_last..subscribe)N)r Z ObserverBaser r Z
SchedulerBaser )r r r )r r skip_last s z skip_last_..skip_last)r r )r r r r r
skip_last_ s (r N) typingr r r r Z reactivexr r r intr __all__r r r r s ",