U
vi5 @ sV d dl mZmZmZ d dlmZmZ edZeee gee f dddZdgZ dS ) )CallableOptionalTypeVar)
Observableabc_T)returnc C s t t t t ddd} | S )N)sourcer c s. dt jt tt j t jd fdd
}t|S )zHides the identity of an observable sequence.
Args:
source: Observable source to hide identity from.
Returns:
An observable sequence that hides the identity of the
source sequence.
N)observer schedulerr c s j | |dS )N)r ) subscribe)r
r r R/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_asobservable.pyr s z8as_observable_..as_observable..subscribe)N)r Z ObserverBaser r Z
SchedulerBaseZDisposableBaser )r r r r
r
as_observable s
z%as_observable_..as_observable)r r )r r r r as_observable_ s r N)
typingr r r Z reactivexr r r r __all__r r r r s