🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 16:11:15 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
observable
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/__pycache__
🔄 Refresh
✏️
Editing: connectableobservable.cpython-38.pyc
Read Only
U v�i� � @ s\ d dl mZmZmZ d dlmZ d dlmZmZ ddl m Z ed�Z G dd� de e �Z d S ) � )�List�Optional�TypeVar)�abc)�CompositeDisposable� Disposable� )� Observable�_Tc s� e Zd ZdZeje eje d�� fdd� Zdej e e ej ej d�dd�Z de ej e ej d �d d �Zdeee d �dd�Z� ZS )�ConnectableObservablezDRepresents an observable that can be connected and disconnected.)�source�subjectc 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__N��observer� scheduler�returnc C s | j j||d�S )N�r )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.TN�r c s d� _ d S r )r r �r r r �dispose& s z.ConnectableObservable.connect.<locals>.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�| �dg��dkr2�� � � d< d�d< 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< d�d< d d���� fdd� }t|�S )Nr r Tr c s$ �� � � d d8 < d�d< d S )Nr r F)r! r )�count� is_connectedr r r r! K s zFConnectableObservable.auto_connect.<locals>.subscribe.<locals>.dispose)r r" r )r r Zshould_connectr! �Zconnectable_subscriptionr$ r% r r# )r r r @ s z5ConnectableObservable.auto_connect.<locals>.subscribe)N)r" r � ObserverBaser r � SchedulerBase�DisposableBaser )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 �<module> s
💾 Save Changes
❌ Cancel