🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 23:12:58 | PHP 8.2.33
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
subject
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/subject/__pycache__
🔄 Refresh
✏️
Editing: replaysubject.cpython-38.pyc
Read Only
U v�i � @ 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� dej�ZG dd� de�ZG dd� dee �ZdS )� N)�deque)�datetime� timedelta)�Any�Deque� NamedTuple�Optional�TypeVar�cast)�ScheduledObserver)�CurrentThreadScheduler� )�abc�typing)�Observer� )�Subject�_Tc @ s2 e Zd Zee ee d�dd�Zdd�dd�ZdS )�RemovableDisposable��subject�observerc 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__N��returnc C s4 | j �� | jjs0| j | jjkr0| jj�| j � d S r )r �disposer Z is_disposed� observers�remove�r 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 )� QueueItem�interval�valueN)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 d�dd�Zedd �d d �Ze dd �d d�Zedd�dd�Zdd�dd�Zdd�� fdd� Z� ZS )� ReplaySubjectz�Represents 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_size�window� 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 �sys�maxsizer+ 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| |�}| j�f | �� | �| 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�_trim�nowr �appendr2 �on_nextr( � exception�on_errorZ is_stopped� on_completed� ensure_active)r r r- �soZ subscription�itemr 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}| j�t||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<dS )z=Notifies all subscribed observers of the end of the sequence.N) r5 r rC rF r- r7 r6 r< r r r r= )r r r7 r r r r �_on_completed_corez s z ReplaySubject._on_completed_corec s* | j � | j�� t� �� W 5 Q R X dS )zuReleases all resources used by the current instance of the ReplaySubject class and unsubscribe all observers.N)r5 r2 rF r. r r" r3 r r r � s zReplaySubject.dispose)NNN)N)r# r$ r% �__doc__r �intr Z RelativeTimer Z SchedulerBaser Z ObserverBaser �DisposableBaser@ r r6 rD � ExceptionrG rH r � __classcell__r r r3 r r* s* �� �� r* )r/ � collectionsr r r r r r r r r r Z$reactivex.observer.scheduledobserverr Zreactivex.schedulerr � r r r r r r rK r r& r* r r r r �<module> s
💾 Save Changes
❌ Cancel