🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 11:34:54 | 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: marbles.cpython-38.pyc
Read Only
U v�i&$ � @ sz d dl Z d dlZd dlmZmZ d dlmZmZmZmZm Z m Z d dl m Z m Z mZmZmZ d dlmZmZ d dlmZ e� ZdZdZd Zd Zd �eeeeg�Ze � e�Z de ej ej eee e e!f ef ee" eej# e e d�dd�Z$de ej eee e e!f ef ee" eej# e e d�dd�Z%de ej ej eee e e!f ef ee" e&ee ej ej e f d�dd�Z'dS ) � N)�datetime� timedelta)�Any�List�Mapping�Optional�Tuple�Union)� Notification� Observable�abc� notification�typing)�CompositeDisposable� Disposable)�NewThreadSchedulerz (\(.*?\))z(-+)z(,)z(#|\||[^-,()#\|]+)�|皙�����?� )�string�timespan�duetime�lookup�error� scheduler�returnc s� |pt }t|t�r ||j }t| ||||dd�}t�� �d� g �d tjt t tj tj d�� ��fdd� }t t tjt d�� ��fdd � } |D ] } | \}} | | �} |�|| � q�t|�S ) NT)r � time_shiftr r � raise_stoppedF)�observerr r c s< �s �� �� � � W 5 Q R X d d��� �fdd� }t|�S )N)r c s8 � �* z�� �� W n tk r( Y nX W 5 Q R X d S �N)�remove� ValueError� )�lockr � observersr" �M/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/marbles.py�disposeD s z'hot.<locals>.subscribe.<locals>.dispose)�appendr )r r r& �� is_stoppedr# r$ )r r% � subscribe; s zhot.<locals>.subscribe)r r c s$ dt jtd d���� �fdd� }|S )N�r �stater c s6 ��( �D ]}�� |� q �jdkr(d� W 5 Q R X d S )N)�C�ET)�accept�kind)r r, r )r) r# r r$ r" r% �actionN s z*hot.<locals>.create_action.<locals>.action)N)r � SchedulerBaser )r r1 r( �r r% � create_actionM s zhot.<locals>.create_action)N)�new_thread_scheduler� isinstancer �now�parse� threading�RLockr � ObserverBaser r r2 �DisposableBaser r ZScheduledAction�schedule_relativer ) r r r r r r � _scheduler�messagesr* r4 �messager r1 r" r( r% �hot! s4 � � �" rA )r r r r r r c sB t | |||dd�� dtjt ttj tjd�� �fdd� }t|�S )NT)r r r r )r � scheduler_r c sN �p |p t � t� �ttjtt f d d�� ��fdd� }�D ] }||� q<�S )N)r@ r c s: | \}� dt jtd d�� �fdd� }����||�� d S )Nr+ c s � � �� d S r )r/ )r r, )r r r" r% r1 z s zEfrom_marbles.<locals>.subscribe.<locals>.schedule_msg.<locals>.action)N)r r2 r �addr= )r@ r r1 �r> Zdispr r3 r% � schedule_msgu s z5from_marbles.<locals>.subscribe.<locals>.schedule_msg)r5 r r r � RelativeTimer r )r rB rE r@ �r? r rD r% r* o s � z from_marbles.<locals>.subscribe)N)r8 r r; r r r2 r< r )r r r r r r* r" rG r% � from_marblesd s � � �rH � �?F)r r r r r r r c st |p t d�� |pi �t|t�r&|�� }t|t�r8|�� }| �dd�} ttttf d�dd��tj tt tj t t f d�� ��fdd � �d �td d���fd d � }d}g }t �| �D ]�} || | �| \} } } } | �r"| dd� �d�}|D ] }||� q��fdd�|D �}|�|� |t| �7 }| �r4|t| �7 }| �rBtd��| r�|| � ��| �}|�|� |t| �7 }q�|S )aV Convert a marble diagram string to a list of messages. Each character in the string will advance time by timespan (exept for space). Characters that are not special (see the table below) will be interpreted as a value to be emitted. numbers will be cast to int or float. Special characters: +--------+--------------------------------------------------------+ | `-` | advance time by timespan | +--------+--------------------------------------------------------+ | `#` | on_error() | +--------+--------------------------------------------------------+ | `|` | on_completed() | +--------+--------------------------------------------------------+ | `(` | open a group of elements sharing the same timestamp | +--------+--------------------------------------------------------+ | `)` | close a group of elements | +--------+--------------------------------------------------------+ | `,` | separate elements in a group | +--------+--------------------------------------------------------+ | space | used to align multiple diagrams, does not advance time | +--------+--------------------------------------------------------+ In a group of elements, the position of the initial `(` determines the timestamp at which grouped elements will be emitted. E.g. `--(12,3,4)--` will emit 12, 3, 4 at 2 * timespan and then advance virtual time by 8 * timespan. Examples: >>> parse("--1--(2,3)-4--|") >>> parse("a--b--c-", lookup={'a': 1, 'b': 2, 'c': 3}) >>> parse("a--b---#", error=ValueError("foo")) Args: string: String with marble diagram timespan: [Optional] duration of each character in second. If not specified, defaults to 0.1s. lookup: [Optional] dict used to convert an element into a specified value. If not specified, defaults to {}. time_shift: [Optional] time used to delay every elements. If not specified, defaults to 0.0s. error: [Optional] exception that will be use in place of the # symbol. If not specified, defaults to Exception('error'). raise_finished: [optional] raise ValueError if elements are declared after on_completed or on_error symbol. Returns: A list of messages defined as a tuple of (timespan, notification). r � � )�elementr c S sP z t | �W S tk rJ zt| �W Y S tk rD | Y Y S X Y nX d S r )�intr! �float�rL r" r" r% � try_number� s zparse.<locals>.try_number)�timerL r c sP |dkr| t �� fS |dkr*| t �� �fS �|�}��||�}| t �|�fS d S )Nr �#)r Z OnCompletedZOnError�getZOnNext)rQ rL �value)�error_�lookup_rP r" r% � map_element� s zparse.<locals>.map_elementFNc s �r � rt d��| dkr d� d S )Nz2Elements cannot be declared after a # or | symbol.)rR r T)r! rO )r) r r" r% � check_stopped� s z parse.<locals>.check_stoppedr � ����,c s g | ]}|d kr� �|��qS )rK r" )�.0�elm)rW � timestampr" r% � <listcomp>� s zparse.<locals>.<listcomp>z+Comma is only allowed in group of elements.)� Exceptionr6 r � total_seconds�replace�strr rN r rF r r r �tokens�findall�split�extend�lenr! r' )r r r r r r rX Ziframer? �results�groupZticksZ comma_errorrL �elementsr] Z grp_messagesr@ r" )rU r) rV rW r r^ rP r% r8 � sL A � � r8 )r r NNN)r NNN)rI r NNF)(�rer9 r r r r r r r r r Z reactivexr r r r Zreactivex.disposabler r Zreactivex.schedulerr r5 Z pattern_groupZ pattern_ticksZpattern_comma_errorZpattern_element�join�pattern�compilerd rc rF ZAbsoluteOrRelativeTimerN r` r2 rA rH �boolr8 r" r" r" r% �<module> sv �� �� E �� & ��
💾 Save Changes
❌ Cancel