🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 20:13:39 | 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: _some.cpython-38.pyc
Read Only
U v�ix � @ sz d dl mZmZmZ d dlmZmZ d dlmZ d dl m Z ed�Z d ee e eee gee f d�dd �Z d gZdS ) � )�Callable�Optional�TypeVar)� Observable�abc)� operators)� Predicate�_TN)� predicate�returnc s t t t t d�� fdd� }|S )N)�sourcer c sB dt jt tt j d�� fdd� }�r:� �t���t� �S t |�S )aP Partially applied operator. Determines whether some element of an observable sequence satisfies a condition if present, else if some items are in the sequence. Example: >>> obs = some(source) Args: predicate -- A function to test each element for a condition. Returns: An observable sequence containing a single element determining whether some elements in the source sequence pass the test in the specified predicate if given, else if some items are in the sequence. N)�observer� schedulerc s2 t d�� fdd� }� fdd�}�j|� j||d�S )N��_c s � � d� � �� d S )NT��on_nextZ on_completedr �r � �J/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_some.pyr $ s z7some_.<locals>.some.<locals>.subscribe.<locals>.on_nextc s � � d� � �� d S )NFr r r r r �on_error( s z8some_.<locals>.some.<locals>.subscribe.<locals>.on_error)r )r � subscriber )r r r r �r r r r s �z&some_.<locals>.some.<locals>.subscribe)N) r Z ObserverBase�boolr Z SchedulerBase�pipe�ops�filter�some_r )r r �r r r �some s ���zsome_.<locals>.some)r r r )r r r r r r s +r )N)�typingr r r Z reactivexr r r r Zreactivex.typingr r r r �__all__r r r r �<module> s � � 1
💾 Save Changes
❌ Cancel