🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 16:54:19 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
operators
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/__pycache__
🔄 Refresh
✏️
Editing: _tomarbles.cpython-38.pyc
Read Only
U v�i � @ st d dl mZmZmZ d dlmZmZ d dlmZ d dl m Z e� Z d e eej d�dd �Z eed �d d �Zd gZdS )� )�Any�List�Optional)� Observable�abc)�NewThreadScheduler)� RelativeTime皙�����?N)�timespan� schedulerc s t t t t d�� fdd� }|S )N)�source�returnc s, dt jt tt j d�� �fdd� }t|�S )ag Convert an observable sequence into a marble diagram string. Args: timespan: [Optional] duration of each character in second. If not specified, defaults to 0.1s. scheduler: [Optional] The scheduler used to run the the input sequence on. Returns: Observable stream. N)�observerr c sp �pt �g ��j�����fdd�� td d�� �fdd� }td d�� ��fdd� }� ��fd d �}��|||�S ) Nc sP �j } | � }| � ��|�}����}dt||d d| � }��|� d S )N�-g @g �?)�nowZ to_seconds�int�append)r �diffZsecsZ timespan_�dashes)�last�resultr r � �O/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_tomarbles.py� add_timespan# s zGto_marbles.<locals>.to_marbles.<locals>.subscribe.<locals>.add_timespan��valuer c s � � �� t| �� d S �N)r � stringify)r )r r r r �on_next. s zBto_marbles.<locals>.to_marbles.<locals>.subscribe.<locals>.on_next)� exceptionr c s: � � �� t| �� ��d�dd� �D ��� ��� d S )N� c s s | ] }|V qd S r r ��.0�nr r r � <genexpr>5 s zVto_marbles.<locals>.to_marbles.<locals>.subscribe.<locals>.on_error.<locals>.<genexpr>)r r r �join� on_completed)r �r r r r r �on_error2 s zCto_marbles.<locals>.to_marbles.<locals>.subscribe.<locals>.on_errorc s6 � � �� d� ��d�dd� �D ��� ��� d S )N�|r c s s | ] }|V qd S r r r! r r r r$ ; s zZto_marbles.<locals>.to_marbles.<locals>.subscribe.<locals>.on_completed.<locals>.<genexpr>)r r r% r& r r' r r r& 8 s zGto_marbles.<locals>.to_marbles.<locals>.subscribe.<locals>.on_completed)�new_thread_schedulerr r � Exception� subscribe)r r r r( r& )r r )r r r r r r r, s z1to_marbles.<locals>.to_marbles.<locals>.subscribe)N)r Z ObserverBase�strr � SchedulerBaser )r r, �r )r r � to_marbles s ��&z to_marbles.<locals>.to_marbles)r r r- )r r r0 r r/ r r0 s 5r0 r c C s t | �}t|�dkr d| }|S )z"Utility for stringifying an event.� z(%s))r- �len)r �stringr r r r E s r )r N)�typingr r r Z reactivexr r Zreactivex.schedulerr Zreactivex.typingr r* r. r0 r- r �__all__r r r r �<module> s � � ;
💾 Save Changes
❌ Cancel