U
viL @ s d dl Z d dlmZmZmZ ddlmZ ddlmZ ddl m
Z
ddl m Z ddl
mZ d d
lmZ ed ZG d d
d
e e ee eje ZdS ) N)ListOptionalTypeVar )abc)
Disposable)DisposedException)
Observable)Observer )InnerSubscription_Tc s e Zd ZdZdd fdd ZddddZdeje e ej
ej dd d
Z edd fd d
Z
edd ddZedd fdd ZeddddZdd fdd ZddddZdd fdd Z ZS ) SubjectzRepresents an object that is both an observable sequence as well
as an observer. Each notification is broadcasted to all subscribed
observers.
N)returnc s* t d| _g | _d | _t | _d S )NF)super__init__ is_disposed observers exception threadingRLocklockself __class__ J/opt/alt/python38/lib/python3.8/site-packages/reactivex/subject/subject.pyr s
zSubject.__init__c C s | j r t d S N)r r r r r r check_disposed s zSubject.check_disposed)observer schedulerr c
C st | j d | | js8| j| t| |W 5 Q R S | jd k rP|| j n| t W 5 Q R S Q R X d S r )
r r Z
is_stoppedr appendr r on_error on_completedr )r r r! r r r _subscribe_core! s
zSubject._subscribe_core)valuer c s* | j | W 5 Q R X t | dS )zNotifies all subscribed observers with the value.
Args:
value: The value to send to all subscribed observers.
N)r r r on_next)r r& r r r r' 2 s zSubject.on_nextc C s4 | j | j }W 5 Q R X |D ]}|| q d S r )r r copyr' )r r& r r r r r
_on_next_core= s zSubject._on_next_core)errorr c s* | j | W 5 Q R X t | dS )zNotifies all subscribed observers with the exception.
Args:
error: The exception to send to all subscribed observers.
N)r r r r# )r r* r r r r# D s zSubject.on_errorc C sD | j | j }| j || _W 5 Q R X |D ]}|| q0d S r )r r r( clearr r# )r r* r r r r r _on_error_coreO s
zSubject._on_error_corec s( | j | W 5 Q R X t dS )z=Notifies all subscribed observers of the end of the sequence.N)r r r r$ r r r r r$ X s zSubject.on_completedc C s< | j | j }| j W 5 Q R X |D ] }| q*d S r )r r r( r+ r$ )r r r r r r _on_completed_core_ s
zSubject._on_completed_corec s2 | j " d| _g | _d| _t W 5 Q R X dS )z0Unsubscribe all observers and release resources.TN)r r r r r disposer r r r r. g s
zSubject.dispose)N)__name__
__module__ __qualname____doc__r r r Z ObserverBaser
r Z
SchedulerBaseZDisposableBaser% r' r) Exceptionr# r, r$ r- r.
__classcell__r r r r r s r )r typingr r r r Z
disposabler Zinternalr Z
observabler r r
Zinnersubscriptionr r
Z SubjectBaser r r r r s