🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 09:28:06 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
operators
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/__pycache__
🔄 Refresh
✏️
Editing: _skip.cpython-38.pyc
Read Only
U v�i4 � @ sd d dl mZmZmZ d dlmZmZ d dlmZ ed�Z e eee gee f d�dd�Z dgZ dS ) � )�Callable�Optional�TypeVar)� Observable�abc)�ArgumentOutOfRangeException�_T)�count�returnc 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|d�S )N)�valuer c s �dkr� � | � n�d8 �d S )Nr � )�on_next)r �r � remaining� �J/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_skip.pyr ! s z7skip_.<locals>.skip.<locals>.subscribe.<locals>.on_next)r )r � subscribeZon_errorZ on_completed)r r r )r r r r r s �z&skip_.<locals>.skip.<locals>.subscribe)N)r Z ObserverBaser r Z SchedulerBaser )r r �r )r r �skip s ��zskip_.<locals>.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 �<module> s ")
💾 Save Changes
❌ Cancel