U
vi
@ s\ d dl mZmZmZ d dlmZ d dlmZmZ ddl m
Z
edZ G dd de
e Z d S )
)ListOptionalTypeVar)abc)CompositeDisposable
Disposable )
Observable_Tc s e Zd ZdZeje eje d fdd Zdej e e
ej ej dddZ
de
ej e
ej d d
d Zdeee d
ddZ ZS )ConnectableObservablezDRepresents an observable that can be connected and
disconnected.)sourcesubjectc s& || _ d| _d | _|| _t d S NF)r
has_subscription subscriptionr super__init__)selfr r
__class__ [/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/connectableobservable.pyr s
z ConnectableObservable.__init__Nobserver schedulerreturnc C s | j j||dS )Nr )r
subscribe)r r r r r r _subscribe_core s z%ConnectableObservable._subscribe_core)r r c sF j s@d _ dd fdd } jj j|d}t|t| _ jS )zConnects the observable.TNr c s
d _ d S r )r r r r r dispose& s z.ConnectableObservable.connect..disposer )r r r r
r r r )r r r! r r r r connect s z ConnectableObservable.connectr )subscriber_countr c sh dg dg| dgdkr2 d< dd< dtjt ttj tjd fdd
}t|S ) a] Returns an observable sequence that stays connected to the
source indefinitely to the observable sequence.
Providing a subscriber_count will cause it to connect() after
that many subscriptions occur. A subscriber_count of 0 will
result in emissions firing immediately without waiting for
subscribers.
Nr FTr c sh d d7 < d ko$d } | |rJ|d< dd< d d fdd }t|S )Nr r Tr c s$ d d8 < dd< d S )Nr r F)r! r )count is_connectedr r r r! K s zFConnectableObservable.auto_connect..subscribe..dispose)r r" r )r r Zshould_connectr! Zconnectable_subscriptionr$ r% r r# )r r r @ s
z5ConnectableObservable.auto_connect..subscribe)N)r" r ObserverBaser
r
SchedulerBaseDisposableBaser )r r# r r r& r auto_connect. s z"ConnectableObservable.auto_connect)N)N)r )__name__
__module__ __qualname____doc__r ZObservableBaser
Z SubjectBaser r' r r( r) r r" intr r*
__classcell__r r r r r s r N)
typingr r r Z reactivexr Zreactivex.disposabler r Z
observabler r
r r r r r s