U
vi @ s d dl Z d dlmZ d dlmZmZ d dlmZmZmZm Z m
Z
m Z d dl m
Z
d dlmZ ddlmZmZ dd lmZ d
d lmZ e
d ZG d
d dejZG dd deZG dd dee ZdS ) N)deque)datetime timedelta)AnyDeque
NamedTupleOptionalTypeVarcast)ScheduledObserver)CurrentThreadScheduler )abctyping)Observer )Subject_Tc @ s2 e Zd Zee ee dddZddddZdS )RemovableDisposablesubjectobserverc C s || _ || _d S Nr )selfr r r P/opt/alt/python38/lib/python3.8/site-packages/reactivex/subject/replaysubject.py__init__ s z RemovableDisposable.__init__Nreturnc C s4 | j | jjs0| j | jjkr0| jj| j d S r )r disposer Z is_disposed observersremover r r r r s
zRemovableDisposable.dispose)__name__
__module__ __qualname__r r r r r r r r r r s r c @ s e Zd ZU eed< eed< dS ) QueueItemintervalvalueN)r# r$ r% r __annotations__r r r r r r& s
r& c s e Zd ZdZdee eej eej dd fdd
Z
dej e eej ej
dddZedd d
d Ze dd d
dZeddddZddddZdd fdd Z ZS )
ReplaySubjectzRepresents an object that is both an observable sequence as well
as an observer. Each notification is broadcasted to all subscribed
and future observers, subject to buffer trimming policies.
N) buffer_sizewindow schedulerr c sT t |dkrtjn|| _|p(t | _|dkr:tj n
| j
|| _ t | _
dS )a~ Initializes a new instance of the ReplaySubject class with
the specified buffer size, window and scheduler.
Args:
buffer_size: [Optional] Maximum element count of the replay
buffer.
window [Optional]: Maximum time length of the replay buffer.
scheduler: [Optional] Scheduler the observers are invoked on.
N)superr sysmaxsizer+ r Z singletonr- r maxZ to_timedeltar, r queue)r r+ r, r- __class__r r r & s
zReplaySubject.__init__)r r- r c C s t | j|}t| |}| jf | | | jj | j| | j D ]}|
|j qF| j d k rp|
| j n| jr~| W 5 Q R X | |S r )r r- r lockZcheck_disposed_trimnowr appendr2 on_nextr( exceptionon_errorZ
is_stopped on_completed
ensure_active)r r r- soZ subscriptionitemr r r _subscribe_core> s
z ReplaySubject._subscribe_core)r7 r c C sH t | j| jkr | j q | jrD|| jd j | jkrD| j q d S )Nr )lenr2 r+ popleftr' r, )r r7 r r r r6 V s zReplaySubject._trim)r( r c C sv | j 6 | j }| jj}| jt||d | | W 5 Q R X |D ]}| | qF|D ]}t
t t |
qZdS )z1Notifies all subscribed observers with the value.)r' r( N)r5 r copyr- r7 r2 r8 r& r6 r9 r
r r r= )r r( r r7 r r r r
_on_next_core] s
zReplaySubject._on_next_core)errorr c C sh | j 2 | j }| j || _| jj}| | W 5 Q R X |D ] }|| t t
t | qBdS )z5Notifies all subscribed observers with the exception.N)
r5 r rC clearr: r- r7 r6 r; r
r r r= )r rE r r7 r r r r _on_error_corel s
z ReplaySubject._on_error_corer c C s` | j , | j }| j | jj}| | W 5 Q R X |D ] }| tt t
| q s