🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 16:52:36 | 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: _take.cpython-38.pyc
Read Only
U v�i� � @ sh d dl mZmZmZ d dlmZmZmZ d dlm Z ed�Z e eee gee f d�dd�Z dgZ dS ) � )�Callable�Optional�TypeVar)� Observable�abc�empty)�ArgumentOutOfRangeException�_T)�count�returnc 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|d�S )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_.<locals>.take.<locals>.subscribe.<locals>.on_next)r )r � subscribeZon_errorr )r r r )r r r r r s �z&take_.<locals>.take.<locals>.subscribe)N)r r Z ObserverBaser r Z SchedulerBaser )r r �r )r r �take s ��ztake_.<locals>.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 �<module> s ",
💾 Save Changes
❌ Cancel