U
vi @ s d dl mZ d dlmZmZmZmZ d dlmZm Z m
Z
d dl m Z d dl
mZ edZeee df eee gee f dd d
Zd
gZd S ) )Future)CallableOptionalTypeVarUnion)
Observableabc from_future)CompositeDisposable)noop_Tz
Future[_T])otherreturnc s8 t | trt| n| tt tt d fdd }|S )N)sourcer c s0 dt jt tt j t jd fdd
}t|S )a Returns the values from the source observable sequence until
the other observable sequence produces a value.
Args:
source: The source observable sequence.
Returns:
An observable sequence containing the elements of the source
sequence up to the point the other sequence interrupted
further propagation.
N)observer schedulerr c s8 t d d fdd }tj |dj| jt|dS )N)_r c s d S )N) on_completed)r r O/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_takeuntil.pyr $ s zHtake_until_..take_until..subscribe..on_completed)r )r r
subscribeZon_errorr )r r r )obsr r r r s z2take_until_..take_until..subscribe)N)r Z ObserverBaser r Z
SchedulerBaseZDisposableBaser )r r r )r r
take_until s z take_until_..take_until)
isinstancer r r r )r
r r r r take_until_ s
r N)asyncior typingr r r r Z reactivexr r r Zreactivex.disposabler
Zreactivex.internalr r r __all__r r r r s (