U
vi @ s^ d dl mZmZmZmZ d dlmZmZ edZeee geee f dddZ dgZ
dS ) )CallableOptionalSetTypeVar)
Observableabc_Treturnc C s t t t tt ddd} | S )zConverts the observable sequence to a set.
Returns an observable sequence with a single value of a set
containing the values from the observable sequence.
)sourcer
c s2 dt jtt tt j t jd fdd
}t|S )N)observer schedulerr
c s0 t d d fdd }jj j||dS )Nr c s t d S )N)Zon_nextset on_completed r sr K/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_toset.pyr s
z@to_set_..to_set..subscribe..on_completed)r
)r subscribeaddZon_error)r r
r r r r r s z*to_set_..to_set..subscribe)N)r Z ObserverBaser r r Z
SchedulerBaseZDisposableBaser )r r r r r to_set s zto_set_..to_set)r r r )r r r r to_set_ s r N) typingr r r r Z reactivexr r r r __all__r r r r s $