U
vâ’iS ã @ s\ d dl mZmZmZmZ d dlmZmZ edƒZe eee gee f dœdd„Z
dgZ dS )é )ÚCallableÚListÚOptionalÚTypeVar)Ú
ObservableÚabcÚ_T)ÚcountÚreturnc s t t t t dœ‡ fdd„ }|S )N)Úsourcer
c s0 dt jt tt j t jdœ‡‡ fdd„
}t|ƒS )aŸ Returns a specified number of contiguous elements from the end of an
observable sequence.
Example:
>>> res = take_last(source)
This operator accumulates a buffer with a length enough to store
elements count elements. Upon completion of the source sequence, this
buffer is drained on the result sequence. This causes the elements to be
delayed.
Args:
source: Number of elements to take from the end of the source
sequence.
Returns:
An observable sequence containing the specified number of elements
from the end of the source sequence.
N)ÚobserverÚ schedulerr
c s< g ‰t d dœ‡‡fdd„ }‡ ‡fdd„}ˆj|ˆ j||dS )N)Úxr
c s$ ˆ | ¡ tˆƒˆ kr ˆ d¡ d S ©Nr )ÚappendÚlenÚpop)r )r Úq© úN/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_takelast.pyÚon_next$ s
zAtake_last_..take_last..subscribe..on_nextc s" ˆrˆ ˆ d¡¡ q ˆ ¡ d S r )r r Ú on_completedr ©r r r r r ) s zFtake_last_..take_last..subscribe..on_completed)r
)r Ú subscribeZon_error)r r
r r )r r r r r s ÿz0take_last_..take_last..subscribe)N)r Z ObserverBaser r Z
SchedulerBaseZDisposableBaser )r r ©r )r r Ú take_last s þýz take_last_..take_last)r r )r r r r r Ú
take_last_ s +r N) Útypingr r r r Z reactivexr r r Úintr Ú__all__r r r r Ú s "/