U
vix @ sz d dl mZmZmZ d dlmZmZ d dlmZ d dl m
Z
edZ d
ee
e eee gee f ddd Z
d gZdS ) )CallableOptionalTypeVar)
Observableabc) operators) Predicate_TN) predicatereturnc s t t t t d fdd }|S )N)sourcer c sB dt jt tt j d fdd
}r: tt 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||dS )N_c s d d S )NTon_nextZ on_completedr r
J/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_some.pyr $ s
z7some_..some..subscribe..on_nextc s d d S )NFr r r r r on_error( s
z8some_..some..subscribe..on_error)r )r subscriber )r
r r r r r r r s z&some_..some..subscribe)N)
r Z ObserverBaseboolr Z
SchedulerBasepipeopsfiltersome_r )r r r
r r some
s zsome_..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 s
1