U
vi
@ sd d dl mZmZmZ ddlmZ ddlmZ ddlm Z ddl
m Z edZ G d d
d
e e Z
d S ) )OptionalTypeVarcast )abc)
Disposable )InnerSubscription)Subject_Tc sx e Zd ZdZdd fdd Zdeje eej ej
dddZ edd d
d Z ddd d
Z
dd fdd Z ZS ) AsyncSubjectzRepresents the result of an asynchronous operation. The last value
before the close notification, or the error received through
on_error, is sent to all subscribed observers.N)returnc s t ttd| _d| _dS )zoCreates a subject that can only receive one value and that value is
cached for all future observations.NF)super__init__r r value has_valueself __class__ O/opt/alt/python38/lib/python3.8/site-packages/reactivex/subject/asyncsubject.pyr s
zAsyncSubject.__init__)observer schedulerr
c
C s | j H | | js8| j| t| |W 5 Q R S | j}| j}| j}W 5 Q R X |rd| | n |r||
| | n| t S )N)
lockZcheck_disposedZ
is_stopped observersappendr exceptionr r Zon_erroron_next on_completedr )r r r exr r r r r _subscribe_core s
z AsyncSubject._subscribe_core)r r
c C s" | j || _d| _W 5 Q R X dS )zRemember the value. Upon completion, the most recently received value
will be passed on to all subscribed observers.
Args:
value: The value to remember until completion
TN)r r r )r r r r r
_on_next_core2 s zAsyncSubject._on_next_corec C sj | j & | j }| j | j}| j}W 5 Q R X |rT|D ]}|| | q:n|D ] }| qXdS )zNotifies all subscribed observers of the end of the sequence. The
most recently received value, if any, will now be passed on to all
subscribed observers.N)r r copyclearr r r r )r r r r r r r r _on_completed_core= s
z AsyncSubject._on_completed_corec s, | j ttd| _t W 5 Q R X dS )z0Unsubscribe all observers and release resources.N)r r r r r disposer r r r r& P s zAsyncSubject.dispose)N)__name__
__module__ __qualname____doc__r r Z ObserverBaser r Z
SchedulerBaseZDisposableBaser! r" r% r&
__classcell__r r r r r s r N)typingr r r r Z
disposabler Zinnersubscriptionr subjectr
r r r r r r s